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

Interface InputReader

All Known Implementing Classes:

BlockInputReader, PipeInputReader

public interface InputReader

Represents the input data transfer to a task.

Method Summary

Modifier and Type	Method	Description
ExecutionPropertyMap<EdgeExecutionProperty>	getProperties()
static int	getSourceParallelism(InputReader inputReader)
IRVertex	getSrcIrVertex()
java.util.List<java.util.concurrent.CompletableFuture<DataUtil.IteratorWithNumBytes>>	read()	Reads input data depending on the communication pattern of the srcVertex.
java.util.concurrent.CompletableFuture<DataUtil.IteratorWithNumBytes>	retry(int index)	Retry reading input data.

Method Detail

read

java.util.List<java.util.concurrent.CompletableFuture<DataUtil.IteratorWithNumBytes>> read()

Reads input data depending on the communication pattern of the srcVertex.

Returns:

the list of iterators.

retry

java.util.concurrent.CompletableFuture<DataUtil.IteratorWithNumBytes> retry(int index)

Retry reading input data.

Parameters:

index - of the failed iterator in the list returned by read().

Returns:

the retried iterator.

getSrcIrVertex

IRVertex getSrcIrVertex()

getProperties

ExecutionPropertyMap<EdgeExecutionProperty> getProperties()

getSourceParallelism

static int getSourceParallelism(InputReader inputReader)