Package org.apache.flink.streaming.api.operators

Interface OnWatermarkCallback<KEY>

  • @Internal
public interface OnWatermarkCallback<KEY>
    A callback registered with the InternalWatermarkCallbackService service. This callback will be invoked for all keys registered with the service, upon reception of a watermark.

    • Method Summary

      All Methods Instance Methods Abstract Methods 
      Modifier and Type Method Description
      void onWatermark​(KEY key, org.apache.flink.streaming.api.watermark.Watermark watermark)
      The action to be triggered upon reception of a watermark.

    • Method Detail

      • onWatermark

        void onWatermark​(KEY key,
                 org.apache.flink.streaming.api.watermark.Watermark watermark)
          throws IOException
        The action to be triggered upon reception of a watermark.
        Parameters:
        key - The current key.
        watermark - The current watermark.
        Throws:
        IOException