Page History

@Public
public interface SourceReader<T, SplitT extends SourceSplit> extends AutoCloseable, CheckpointListener {   
    ...

    /**
     * Provide SourceReader with a runnable that can be used to emit watermark.
     *
     * If SourceReader wants to own the responsibility of invoking WatermarkGenerator#onPeriodicEmit,
     * it should override should override this method and return true. ifAnd itSourceReader wantsshould torespective
 own the responsibility
  * pipeline.auto-watermark-interval if it decides *to ofemit invokingwatermark WatermarkGenerator#onPeriodicEmitperiodically.
     *
     * @return true iff the caller should avoid triggering WatermarkGenerator#onPeriodicEmit.
     */
    default boolean delegateWatermarkPeriodicEmit(Runnable onWatermarkEmit) {
        return false;
    }
}