Uses of Package
org.apache.nemo.runtime.executor.datatransfer
-
Packages that use org.apache.nemo.runtime.executor.datatransfer Package Description org.apache.nemo.runtime.executor.datatransfer org.apache.nemo.runtime.executor.task -
Classes in org.apache.nemo.runtime.executor.datatransfer used by org.apache.nemo.runtime.executor.datatransfer Class Description InputReader Represents the input data transfer to a task.InputWatermarkManager An interface for tracking input watermarks among multiple input streams.NextIntraTaskOperatorInfo Contains information for next operator: -- edgeIndex: the index of edge to next operator.OutputWriter Represents the output data transfer from a task. -
Classes in org.apache.nemo.runtime.executor.datatransfer used by org.apache.nemo.runtime.executor.task Class Description IntermediateDataIOFactory A factory that producesInputReader
andOutputWriter
.