public interface WatermarkFunction<T>
Modifier and Type | Method and Description |
---|---|
java.lang.Long |
getOutputWatermark()
Returns the output watermark.
|
java.util.Collection<T> |
processWatermark(long watermark)
Processes the input watermark coming from upstream operators.
|
java.util.Collection<T> processWatermark(long watermark)
watermark
- input watermarkjava.lang.Long getOutputWatermark()
FlatMapFunction
.
processWatermark(long)
function.