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

Packages that use InputReader

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

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

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

Modifier and Type	Class	Description
class	BlockInputReader	Represents the input data transfer to a task.
class	PipeInputReader	Represents the input data transfer to a task.

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

Modifier and Type	Method	Description
InputReader	IntermediateDataIOFactory.createReader(java.lang.String dstTaskId, IRVertex srcIRVertex, RuntimeEdge runtimeEdge)	Creates an InputReader between two stages.

Methods in org.apache.nemo.runtime.executor.datatransfer with parameters of type InputReader

Modifier and Type	Method	Description
static int	InputReader.getSourceParallelism(InputReader inputReader)