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

Class OperatorTopologyStructImpl

java.lang.Object

org.apache.reef.io.network.group.impl.task.OperatorTopologyStructImpl

All Implemented Interfaces:

OperatorTopologyStruct

public class OperatorTopologyStructImpl
extends Object
implements OperatorTopologyStruct

Constructor Summary

Constructors

Constructor and Description
OperatorTopologyStructImpl(Class<? extends Name<String>> groupName, Class<? extends Name<String>> operName, String selfId, String driverId, Sender sender, int version)
OperatorTopologyStructImpl(OperatorTopologyStruct topology)

Method Summary

Methods

Modifier and Type	Method and Description
void	addAsData(GroupCommunicationMessage msg)
Collection<? extends NodeStruct>	getChildren()
String	getDriverId()
Class<? extends Name<String>>	getGroupName()
Class<? extends Name<String>>	getOperName()
NodeStruct	getParent()
String	getSelfId()
Sender	getSender()
int	getVersion()
boolean	hasChanges()
byte[]	recvFromChildren() Receive data from all children as a single byte array.
<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[] data, ReefNetworkGroupCommProtos.GroupCommMessage.Type msgType)
void	setChanges(boolean changes)
String	toString()
void	update(GroupCommunicationMessage msg) Updates the topology structure with the received message.
void	update(Set<GroupCommunicationMessage> deletionDeltas)

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

OperatorTopologyStructImpl

public OperatorTopologyStructImpl(Class<? extends Name<String>> groupName,
                          Class<? extends Name<String>> operName,
                          String selfId,
                          String driverId,
                          Sender sender,
                          int version)

OperatorTopologyStructImpl

public OperatorTopologyStructImpl(OperatorTopologyStruct topology)

Method Detail

toString

public String toString()

Overrides:

toString in class Object

getParent

public NodeStruct getParent()

Specified by:

getParent in interface OperatorTopologyStruct

getChildren

public Collection<? extends NodeStruct> getChildren()

Specified by:

getChildren in interface OperatorTopologyStruct

getGroupName

public Class<? extends Name<String>> getGroupName()

Specified by:

getGroupName in interface OperatorTopologyStruct

getOperName

public Class<? extends Name<String>> getOperName()

Specified by:

getOperName in interface OperatorTopologyStruct

getSelfId

public String getSelfId()

Specified by:

getSelfId in interface OperatorTopologyStruct

getDriverId

public String getDriverId()

Specified by:

getDriverId in interface OperatorTopologyStruct

getSender

public Sender getSender()

Specified by:

getSender in interface OperatorTopologyStruct

hasChanges

public boolean hasChanges()

Specified by:

hasChanges in interface OperatorTopologyStruct

getVersion

public int getVersion()

Specified by:

getVersion in interface OperatorTopologyStruct

addAsData

public void addAsData(GroupCommunicationMessage msg)

Specified by:

addAsData in interface OperatorTopologyStruct

sendToParent

public void sendToParent(byte[] data,
                ReefNetworkGroupCommProtos.GroupCommMessage.Type msgType)

Specified by:

sendToParent in interface OperatorTopologyStruct

sendToChildren

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

Specified by:

sendToChildren in interface OperatorTopologyStruct

sendToChildren

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

Specified by:

sendToChildren in interface OperatorTopologyStruct

recvFromParent

public byte[] recvFromParent(ReefNetworkGroupCommProtos.GroupCommMessage.Type msgType)

Specified by:

recvFromParent in interface OperatorTopologyStruct

recvFromChildren

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

Specified by:

recvFromChildren in interface OperatorTopologyStruct

recvFromChildren

public byte[] recvFromChildren()

Receive data from all children as a single byte array. Messages from children are simply byte-concatenated. This method is currently used only by the Gather operator.

Specified by:

recvFromChildren in interface OperatorTopologyStruct

Returns:

gathered data as a byte array

update

public void update(GroupCommunicationMessage msg)

Updates the topology structure with the received message. Does not make assumptions about msg order Tries to handle OOS msgs

Expects only control messages

Specified by:

update in interface OperatorTopologyStruct

update

public void update(Set<GroupCommunicationMessage> deletionDeltas)

Specified by:

update in interface OperatorTopologyStruct

setChanges

public void setChanges(boolean changes)

Specified by:

setChanges in interface OperatorTopologyStruct