org.apache.reef.io.network.group.api.task

Interface OperatorTopology

All Known Implementing Classes:

OperatorTopologyImpl

public interface OperatorTopology

Represents the local topology of tasks for an operator. It provides methods to send/rcv from parents and children

Every operator is an EventHandler<GroupCommunicationMessage> and it will use an instance of this type to delegate the handling of the message and also uses it to communicate with its parents and children

This is an operator facing interface. The actual topology is maintained in OperatorTopologyStruct. Current strategy is to maintain two versions of the topology and current operations are always delegated to effectiveTopology and the baseTopology is updated while initialization and when user calls updateTopology. So this is only a wrapper around the two versions of topologies and manages when to create/update them based on the messages from the driver.

Method Summary

Methods

Modifier and Type	Method and Description
void	handle(GroupCommunicationMessage msg)
void	initialize()
byte[]	recvFromChildren()
<T> T	recvFromChildren(Reduce.ReduceFunction<T> redFunc, Codec<T> dataCodec)
byte[]	recvFromParent(ReefNetworkGroupCommProtos.GroupCommMessage.Type msgType)
void	sendToChildren(byte[] data, ReefNetworkGroupCommProtos.GroupCommMessage.Type msgType)
void	sendToChildren(Map<String,byte[]> dataMap, ReefNetworkGroupCommProtos.GroupCommMessage.Type msgType)
void	sendToParent(byte[] encode, ReefNetworkGroupCommProtos.GroupCommMessage.Type reduce)

Method Detail

handle

void handle(GroupCommunicationMessage msg)

sendToParent

void sendToParent(byte[] encode,
                ReefNetworkGroupCommProtos.GroupCommMessage.Type reduce)
                  throws ParentDeadException

Throws:

ParentDeadException

recvFromParent

byte[] recvFromParent(ReefNetworkGroupCommProtos.GroupCommMessage.Type msgType)
                      throws ParentDeadException

Throws:

ParentDeadException

sendToChildren

void sendToChildren(byte[] data,
                  ReefNetworkGroupCommProtos.GroupCommMessage.Type msgType)
                    throws ParentDeadException

Throws:

ParentDeadException

sendToChildren

void sendToChildren(Map<String,byte[]> dataMap,
                  ReefNetworkGroupCommProtos.GroupCommMessage.Type msgType)
                    throws ParentDeadException

Throws:

ParentDeadException

recvFromChildren

<T> T recvFromChildren(Reduce.ReduceFunction<T> redFunc,
                     Codec<T> dataCodec)
                   throws ParentDeadException

Throws:

ParentDeadException

recvFromChildren

byte[] recvFromChildren()
                        throws ParentDeadException

Throws:

ParentDeadException

initialize

void initialize()
                throws ParentDeadException

Throws:

ParentDeadException