Class SideInputTransform<T>

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

    public final class SideInputTransform<T>
    extends LatencymarkEmitTransform<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)
        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.
        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.
        watermark - watermark
      • close

        public void close()
        Description copied from interface: Transform
        Close the transform.
      • toString

        public java.lang.String toString()
        toString in class java.lang.Object