Org.Apache.REEF.Network.Group.Task.IOperatorTopology< T > Interface Template Reference

Contains the Operator's topology graph. More...

Inherited by Org.Apache.REEF.Network.Group.Task.Impl.OperatorTopology< T >.

Public Member Functions
void	Initialize ()
	Initializes operator topology. More...
void	SendToParent (T message, MessageType type)
	Sends the message to the parent Task. More...
void	SendToChildren (T message, MessageType type)
	Sends the message to all child Tasks. More...
void	ScatterToChildren (IList< T > messages, MessageType type)
	Splits the list of messages up evenly and sends each sublist to the child Tasks. More...
void	ScatterToChildren (IList< T > messages, int count, MessageType type)
	Splits the list of messages up into chunks of the specified size and sends each sublist to the child Tasks. More...
void	ScatterToChildren (IList< T > messages, List< string > order, MessageType type)
	Splits the list of messages up into chunks of the specified size and sends each sublist to the child Tasks in the specified order. More...
T	ReceiveFromParent ()
	Receive an incoming message from the parent Task. More...
IList< T >	ReceiveListFromParent ()
	Receive a list of incoming messages from the parent Task. More...
T	ReceiveFromChildren (IReduceFunction< T > reduceFunction)
	Receives all messages from child Tasks and reduces them with the given IReduceFunction. More...
bool	HasChildren ()
	Checks if the node has children More...

Detailed Description

Contains the Operator's topology graph.

Used to send or receive messages to/from operators in the same Communication Group.

Template Parameters

T	The type of message

Member Function Documentation

bool Org.Apache.REEF.Network.Group.Task.IOperatorTopology< T >.HasChildren

(

)

Checks if the node has children

Returns

true if children are there, false otherwise

Implemented in Org.Apache.REEF.Network.Group.Task.Impl.OperatorTopology< T >.

void Org.Apache.REEF.Network.Group.Task.IOperatorTopology< T >.Initialize

(

)

Initializes operator topology.

Waits until all Tasks in the CommunicationGroup have registered themselves with the Name Service.

Implemented in Org.Apache.REEF.Network.Group.Task.Impl.OperatorTopology< T >.

T Org.Apache.REEF.Network.Group.Task.IOperatorTopology< T >.ReceiveFromChildren

(

IReduceFunction< T >

reduceFunction

)

Receives all messages from child Tasks and reduces them with the given IReduceFunction.

Parameters

reduceFunction

The class used to reduce messages

Returns

The result of reducing messages

Implemented in Org.Apache.REEF.Network.Group.Task.Impl.OperatorTopology< T >.

T Org.Apache.REEF.Network.Group.Task.IOperatorTopology< T >.ReceiveFromParent

(

)

Receive an incoming message from the parent Task.

Returns

The parent Task's message

Implemented in Org.Apache.REEF.Network.Group.Task.Impl.OperatorTopology< T >.

IList<T> Org.Apache.REEF.Network.Group.Task.IOperatorTopology< T >.ReceiveListFromParent

(

)

Receive a list of incoming messages from the parent Task.

Returns

The parent Task's list of messages

Implemented in Org.Apache.REEF.Network.Group.Task.Impl.OperatorTopology< T >.

void Org.Apache.REEF.Network.Group.Task.IOperatorTopology< T >.ScatterToChildren	(	IList< T >	messages,
		MessageType	type
	)

Splits the list of messages up evenly and sends each sublist to the child Tasks.

Parameters

messages	The list of messages to scatter
type	The message type

Implemented in Org.Apache.REEF.Network.Group.Task.Impl.OperatorTopology< T >.

void Org.Apache.REEF.Network.Group.Task.IOperatorTopology< T >.ScatterToChildren	(	IList< T >	messages,
		int	count,
		MessageType	type
	)

Splits the list of messages up into chunks of the specified size and sends each sublist to the child Tasks.

Parameters

messages	The list of messages to scatter
count	The size of each sublist
type	The message type

Implemented in Org.Apache.REEF.Network.Group.Task.Impl.OperatorTopology< T >.

void Org.Apache.REEF.Network.Group.Task.IOperatorTopology< T >.ScatterToChildren	(	IList< T >	messages,
		List< string >	order,
		MessageType	type
	)

Splits the list of messages up into chunks of the specified size and sends each sublist to the child Tasks in the specified order.

Parameters

messages	The list of messages to scatter
order	The order to send messages
type	The message type

Implemented in Org.Apache.REEF.Network.Group.Task.Impl.OperatorTopology< T >.

void Org.Apache.REEF.Network.Group.Task.IOperatorTopology< T >.SendToChildren	(	T	message,
		MessageType	type
	)

Sends the message to all child Tasks.

Parameters

message	The message to send
type	The message type

Implemented in Org.Apache.REEF.Network.Group.Task.Impl.OperatorTopology< T >.

void Org.Apache.REEF.Network.Group.Task.IOperatorTopology< T >.SendToParent	(	T	message,
		MessageType	type
	)

Sends the message to the parent Task.

Parameters

message	The message to send
type	The message type

Implemented in Org.Apache.REEF.Network.Group.Task.Impl.OperatorTopology< T >.

---

The documentation for this interface was generated from the following file:

• lang/cs/Org.Apache.REEF.Network/Group/Task/IOperatorTopology.cs