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

Inherits Org.Apache.REEF.Network.Group.Task.IOperatorTopology< T >, and IObserver< GeneralGroupCommunicationMessage >.

Public Member Functions
void	Initialize ()
	Initializes operator topology. More...

void	OnNext (GeneralGroupCommunicationMessage gcm)
	Handles the incoming GroupCommunicationMessage. 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...

void	OnError (Exception error)

void	OnCompleted ()

bool	HasChildren ()
	Checks if the node has children More...

Detailed Description

Contains the Operator's topology graph.

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

Template Parameters

T	The message type

Member Function Documentation

bool Org.Apache.REEF.Network.Group.Task.Impl.OperatorTopology< T >.HasChildren ( )

inline

Checks if the node has children

Returns: true if children are there, false otherwise

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

void Org.Apache.REEF.Network.Group.Task.Impl.OperatorTopology< T >.Initialize ( )

inline

Initializes operator topology.

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

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

void Org.Apache.REEF.Network.Group.Task.Impl.OperatorTopology< T >.OnCompleted ( )

inline

void Org.Apache.REEF.Network.Group.Task.Impl.OperatorTopology< T >.OnError ( Exception error )

inline

void Org.Apache.REEF.Network.Group.Task.Impl.OperatorTopology< T >.OnNext ( GeneralGroupCommunicationMessage gcm )

inline

Handles the incoming GroupCommunicationMessage.

Updates the sending node's message queue.

Parameters

gcm	The incoming message

T Org.Apache.REEF.Network.Group.Task.Impl.OperatorTopology< T >.ReceiveFromChildren ( IReduceFunction< T > reduceFunction )

inline

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

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

T Org.Apache.REEF.Network.Group.Task.Impl.OperatorTopology< T >.ReceiveFromParent ( )

inline

Receive an incoming message from the parent Task.

Returns: The parent Task's message

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

IList<T> Org.Apache.REEF.Network.Group.Task.Impl.OperatorTopology< T >.ReceiveListFromParent ( )

inline

Receive a list of incoming messages from the parent Task.

Returns: The parent Task's list of messages

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

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

inline

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

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

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

inline

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

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

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

inline

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

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

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

inline

Sends the message to all child Tasks.

Parameters

message	The message to send
type	The message type

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

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

inline

Sends the message to the parent Task.

Parameters

message	The message to send
type	The message type

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

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

lang/cs/Org.Apache.REEF.Network/Group/Task/Impl/OperatorTopology.cs

Public Member Functions

Detailed Description

Member Function Documentation