public class OperatorTopologyStructImpl extends Object implements OperatorTopologyStruct
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) |
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() |
<T> T |
recvFromChildren(Reduce.ReduceFunction<T> redFunc,
Codec<T> dataCodec) |
byte[] |
recvFromParent() |
void |
sendToChildren(byte[] data,
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) |
public OperatorTopologyStructImpl(Class<? extends Name<String>> groupName, Class<? extends Name<String>> operName, String selfId, String driverId, Sender sender, int version)
public OperatorTopologyStructImpl(OperatorTopologyStruct topology)
public NodeStruct getParent()
getParent
in interface OperatorTopologyStruct
public Collection<? extends NodeStruct> getChildren()
getChildren
in interface OperatorTopologyStruct
public Class<? extends Name<String>> getGroupName()
getGroupName
in interface OperatorTopologyStruct
public Class<? extends Name<String>> getOperName()
getOperName
in interface OperatorTopologyStruct
public String getSelfId()
getSelfId
in interface OperatorTopologyStruct
public String getDriverId()
getDriverId
in interface OperatorTopologyStruct
public Sender getSender()
getSender
in interface OperatorTopologyStruct
public boolean hasChanges()
hasChanges
in interface OperatorTopologyStruct
public int getVersion()
getVersion
in interface OperatorTopologyStruct
public void addAsData(GroupCommunicationMessage msg)
addAsData
in interface OperatorTopologyStruct
public void sendToParent(byte[] data, ReefNetworkGroupCommProtos.GroupCommMessage.Type msgType)
sendToParent
in interface OperatorTopologyStruct
public void sendToChildren(byte[] data, ReefNetworkGroupCommProtos.GroupCommMessage.Type msgType)
sendToChildren
in interface OperatorTopologyStruct
public byte[] recvFromParent()
recvFromParent
in interface OperatorTopologyStruct
public <T> T recvFromChildren(Reduce.ReduceFunction<T> redFunc, Codec<T> dataCodec)
recvFromChildren
in interface OperatorTopologyStruct
public void update(GroupCommunicationMessage msg)
update
in interface OperatorTopologyStruct
public void update(Set<GroupCommunicationMessage> deletionDeltas)
update
in interface OperatorTopologyStruct
public void setChanges(boolean changes)
setChanges
in interface OperatorTopologyStruct
Copyright © 2015 The Apache Software Foundation. All rights reserved.