public interface OperatorTopology
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.
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) |
void handle(GroupCommunicationMessage msg)
void sendToParent(byte[] encode, ReefNetworkGroupCommProtos.GroupCommMessage.Type reduce) throws ParentDeadException
ParentDeadException
byte[] recvFromParent(ReefNetworkGroupCommProtos.GroupCommMessage.Type msgType) throws ParentDeadException
ParentDeadException
void sendToChildren(byte[] data, ReefNetworkGroupCommProtos.GroupCommMessage.Type msgType) throws ParentDeadException
ParentDeadException
void sendToChildren(Map<String,byte[]> dataMap, ReefNetworkGroupCommProtos.GroupCommMessage.Type msgType) throws ParentDeadException
ParentDeadException
<T> T recvFromChildren(Reduce.ReduceFunction<T> redFunc, Codec<T> dataCodec) throws ParentDeadException
ParentDeadException
byte[] recvFromChildren() throws ParentDeadException
ParentDeadException
void initialize() throws ParentDeadException
ParentDeadException
Copyright © 2017 The Apache Software Foundation. All rights reserved.