Class SideInputTransform<T>

  • Type Parameters:
    T - input/output type.
    All Implemented Interfaces:
    Serializable, Transform<org.apache.beam.sdk.util.WindowedValue<T>,​org.apache.beam.sdk.util.WindowedValue<SideInputElement<T>>>

    public final class SideInputTransform<T>
    extends Object
    implements Transform<org.apache.beam.sdk.util.WindowedValue<T>,​org.apache.beam.sdk.util.WindowedValue<SideInputElement<T>>>
    Side input transform implementation. TODO #297: Consider Removing SideInputTransform
    See Also:
    Serialized Form
    • Constructor Detail

      • SideInputTransform

        public SideInputTransform​(int index)
        Constructor.
        Parameters:
        index - side input index.
    • Method Detail

      • onData

        public void onData​(org.apache.beam.sdk.util.WindowedValue<T> element)
        Description copied from interface: Transform
        On data received.
        Specified by:
        onData in interface Transform<org.apache.beam.sdk.util.WindowedValue<T>,​org.apache.beam.sdk.util.WindowedValue<SideInputElement<T>>>
        Parameters:
        element - data received.
      • onWatermark

        public void onWatermark​(Watermark watermark)
        Description copied from interface: Transform
        On watermark received. This method should be called for the minimum watermark among input streams (input watermark). Transform may emit collected data after receiving watermarks.
        Specified by:
        onWatermark in interface Transform<org.apache.beam.sdk.util.WindowedValue<T>,​org.apache.beam.sdk.util.WindowedValue<SideInputElement<T>>>
        Parameters:
        watermark - watermark
      • close

        public void close()
        Description copied from interface: Transform
        Close the transform.
        Specified by:
        close in interface Transform<org.apache.beam.sdk.util.WindowedValue<T>,​org.apache.beam.sdk.util.WindowedValue<SideInputElement<T>>>