T
- The type of the emitted records.@Internal public class BatchTimestampsAndWatermarks<T> extends Object implements TimestampsAndWatermarks<T>
TimestampsAndWatermarks
to be used during batch execution of a
program. Batch execution has no watermarks, so all watermark related operations in this
implementation are no-ops.Constructor and Description |
---|
BatchTimestampsAndWatermarks(TimestampAssigner<T> timestamps)
Creates a new BatchTimestampsAndWatermarks with the given TimestampAssigner.
|
Modifier and Type | Method and Description |
---|---|
ReaderOutput<T> |
createMainOutput(PushingAsyncDataInput.DataOutput<T> output)
Creates the ReaderOutput for the source reader, than internally runs the timestamp extraction
and watermark generation.
|
void |
startPeriodicWatermarkEmits()
Starts emitting periodic watermarks, if this implementation produces watermarks, and if
periodic watermarks are configured.
|
void |
stopPeriodicWatermarkEmits()
Stops emitting periodic watermarks.
|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
createBatchEventTimeLogic, createStreamingEventTimeLogic
public BatchTimestampsAndWatermarks(TimestampAssigner<T> timestamps)
public ReaderOutput<T> createMainOutput(PushingAsyncDataInput.DataOutput<T> output)
TimestampsAndWatermarks
createMainOutput
in interface TimestampsAndWatermarks<T>
public void startPeriodicWatermarkEmits()
TimestampsAndWatermarks
Periodic watermarks are produced by periodically calling the WatermarkGenerator.onPeriodicEmit(WatermarkOutput)
method of the underlying Watermark Generators.
startPeriodicWatermarkEmits
in interface TimestampsAndWatermarks<T>
public void stopPeriodicWatermarkEmits()
TimestampsAndWatermarks
stopPeriodicWatermarkEmits
in interface TimestampsAndWatermarks<T>
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.