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

Interface OperatorTopologyStruct

All Known Implementing Classes:

OperatorTopologyStructImpl

public interface OperatorTopologyStruct

The actual local topology maintaining the children and parent that reacts to update and data msgs. The actual nodes are represented by NodeStruct and it handles receiving and providing data

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()
<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 b)
void	update(GroupCommunicationMessage msg)
void	update(Set<GroupCommunicationMessage> deletionDeltas)

Method Detail

getGroupName

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

getOperName

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

getSelfId

String getSelfId()

getVersion

int getVersion()

getParent

NodeStruct getParent()

getChildren

Collection<? extends NodeStruct> getChildren()

getDriverId

String getDriverId()

getSender

Sender getSender()

hasChanges

boolean hasChanges()

setChanges

void setChanges(boolean b)

addAsData

void addAsData(GroupCommunicationMessage msg)

update

void update(Set<GroupCommunicationMessage> deletionDeltas)

update

void update(GroupCommunicationMessage msg)

sendToParent

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

recvFromParent

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

sendToChildren

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

sendToChildren

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

recvFromChildren

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

recvFromChildren

byte[] recvFromChildren()