Class SingleInputWatermarkManager
- java.lang.Object
-
- org.apache.nemo.runtime.executor.datatransfer.SingleInputWatermarkManager
-
- All Implemented Interfaces:
InputWatermarkManager
public final class SingleInputWatermarkManager extends java.lang.Object implements InputWatermarkManager
This is a special implementation for single input data stream for optimization.
-
-
Constructor Summary
Constructors Constructor Description SingleInputWatermarkManager(OutputCollector watermarkCollector)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
trackAndEmitWatermarks(int edgeIndex, Watermark watermark)
This just forwards watermarks to the next operator because it has one data stream.
-
-
-
Constructor Detail
-
SingleInputWatermarkManager
public SingleInputWatermarkManager(OutputCollector watermarkCollector)
-
-
Method Detail
-
trackAndEmitWatermarks
public void trackAndEmitWatermarks(int edgeIndex, Watermark watermark)
This just forwards watermarks to the next operator because it has one data stream.- Specified by:
trackAndEmitWatermarks
in interfaceInputWatermarkManager
- Parameters:
edgeIndex
- edge indexwatermark
- watermark
-
-