Package org.apache.nemo.runtime.executor.transfer

Class LocalInputContext

java.lang.Object

org.apache.nemo.runtime.executor.transfer.LocalTransferContext

org.apache.nemo.runtime.executor.transfer.LocalInputContext

public final class LocalInputContext
extends LocalTransferContext

This class provides a data transfer interface to the receiver side when both the sender and the receiver are in the same executor. Since the sender doesn't serialize data, the receiver doesn't need to deserialize data when retrieving them.

Constructor Summary

Constructors

Constructor	Description
LocalInputContext(LocalOutputContext localOutputContext)	Creates a new local input context and connect it to localOutputContext.

Method Summary

Modifier and Type	Method	Description
org.apache.nemo.runtime.executor.transfer.LocalInputContext.LocalInputIterator	getIterator()	Creates a new iterator which iterates the receive elements from the sender.
boolean	isOutputContextClosed()	Checks if the connected output context has already been closed.

Methods inherited from class org.apache.nemo.runtime.executor.transfer.LocalTransferContext

getDstTaskIndex, getEdgeId, getExecutorId, getSrcTaskIndex

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

LocalInputContext

public LocalInputContext(LocalOutputContext localOutputContext)

Creates a new local input context and connect it to localOutputContext.

Parameters:

localOutputContext - the local output context to which this local input context is connected

Method Detail

isOutputContextClosed

public boolean isOutputContextClosed()

Checks if the connected output context has already been closed. It is for testing purpose.

Returns:

true if the connected output context has already been closed.

getIterator

public org.apache.nemo.runtime.executor.transfer.LocalInputContext.LocalInputIterator getIterator()

Creates a new iterator which iterates the receive elements from the sender.

Returns:

iterator that iterates the received elements.