THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
Code Block | ||||
---|---|---|---|---|
| ||||
@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; } } |
...