Class SignalTransform

  • All Implemented Interfaces:
    java.io.Serializable, Transform<java.lang.Void,​java.lang.Void>

    public final class SignalTransform
    extends NoWatermarkEmitTransform<java.lang.Void,​java.lang.Void>
    This class evokes run-time pass when there's no need to transfer any run-time information.
    See Also:
    Serialized Form
    • Constructor Detail

      • SignalTransform

        public SignalTransform()
    • Method Detail

      • prepare

        public void prepare​(Transform.Context context,
                            OutputCollector<java.lang.Void> oc)
        Description copied from interface: Transform
        Prepare the transform.
        Parameters:
        context - of the transform.
        oc - that collects outputs.
      • onData

        public void onData​(java.lang.Void element)
        Description copied from interface: Transform
        On data received.
        Parameters:
        element - data received.
      • close

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

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