Uses of Interface
org.apache.nemo.runtime.executor.datatransfer.InputWatermarkManager

Packages that use InputWatermarkManager

Package	Description
org.apache.nemo.runtime.executor.datatransfer

Uses of InputWatermarkManager in org.apache.nemo.runtime.executor.datatransfer

Classes in org.apache.nemo.runtime.executor.datatransfer that implement InputWatermarkManager

Modifier and Type	Class	Description
class	MultiInputWatermarkManager	This tracks the minimum input watermark among multiple input streams.
class	SingleInputWatermarkManager	This is a special implementation for single input data stream for optimization.

Methods in org.apache.nemo.runtime.executor.datatransfer that return InputWatermarkManager

Modifier and Type	Method	Description
InputWatermarkManager	NextIntraTaskOperatorInfo.getWatermarkManager()

Constructors in org.apache.nemo.runtime.executor.datatransfer with parameters of type InputWatermarkManager

Constructor	Description
DataFetcherOutputCollector(OperatorVertex nextOperatorVertex, int edgeIndex, InputWatermarkManager watermarkManager)	It forwards output to the next operator.
NextIntraTaskOperatorInfo(int edgeIndex, OperatorVertex nextOperator, InputWatermarkManager watermarkManager)