Package org.apache.flink.table.runtime.collector

Interface ListenableCollector.CollectListener<T>

  • Enclosing class:
    ListenableCollector<T>
    public static interface ListenableCollector.CollectListener<T>
    An interface can listen on collecting original record.

    • Method Summary

      All Methods Instance Methods Default Methods 
      Modifier and Type Method Description
      default void onCollect​(T record)
      A callback method when an original record was collected, do nothing by default.

    • Method Detail

      • onCollect

        default void onCollect​(T record)
        A callback method when an original record was collected, do nothing by default.