Package org.apache.beam.runners.spark.util

Class CachedSideInputReader

java.lang.Object
org.apache.beam.runners.spark.util.CachedSideInputReader
All Implemented Interfaces:
org.apache.beam.runners.core.SideInputReader
public class CachedSideInputReader extends Object implements org.apache.beam.runners.core.SideInputReader
SideInputReader that caches materialized views.

  • Method Summary

    Modifier and Type
    Method
    Description
    <T> boolean
    contains(org.apache.beam.sdk.values.PCollectionView<T> view)
     
    <T> @Nullable T
    get(org.apache.beam.sdk.values.PCollectionView<T> view, org.apache.beam.sdk.transforms.windowing.BoundedWindow window)
     
    boolean
    isEmpty()
     
    static CachedSideInputReader
    of(org.apache.beam.runners.core.SideInputReader delegate)
    Create a new cached SideInputReader.

    Methods inherited from class java.lang.Object

    clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

  • Method Details

    • of

      public static CachedSideInputReader of(org.apache.beam.runners.core.SideInputReader delegate)
      Create a new cached SideInputReader.
      Parameters:
      delegate - wrapped reader
      Returns:
      cached reader

    • get

      public <T> @Nullable T get(org.apache.beam.sdk.values.PCollectionView<T> view, org.apache.beam.sdk.transforms.windowing.BoundedWindow window)
      Specified by:
      get in interface org.apache.beam.runners.core.SideInputReader

    • contains

      public <T> boolean contains(org.apache.beam.sdk.values.PCollectionView<T> view)
      Specified by:
      contains in interface org.apache.beam.runners.core.SideInputReader

    • isEmpty

      public boolean isEmpty()
      Specified by:
      isEmpty in interface org.apache.beam.runners.core.SideInputReader