public class OperatorTopologyImpl extends Object implements OperatorTopology
Constructor and Description |
---|
OperatorTopologyImpl(Class<? extends Name<String>> groupName,
Class<? extends Name<String>> operName,
String selfId,
String driverId,
Sender sender,
int version) |
Modifier and Type | Method and Description |
---|---|
void |
handle(GroupCommunicationMessage msg)
Handle messages meant for this operator.
|
void |
initialize() |
<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) |
public void handle(GroupCommunicationMessage msg)
handle
in interface OperatorTopology
public void initialize() throws ParentDeadException
initialize
in interface OperatorTopology
ParentDeadException
public void sendToParent(byte[] data, ReefNetworkGroupCommProtos.GroupCommMessage.Type msgType) throws ParentDeadException
sendToParent
in interface OperatorTopology
ParentDeadException
public void sendToChildren(byte[] data, ReefNetworkGroupCommProtos.GroupCommMessage.Type msgType) throws ParentDeadException
sendToChildren
in interface OperatorTopology
ParentDeadException
public byte[] recvFromParent() throws ParentDeadException
recvFromParent
in interface OperatorTopology
ParentDeadException
public <T> T recvFromChildren(Reduce.ReduceFunction<T> redFunc, Codec<T> dataCodec) throws ParentDeadException
recvFromChildren
in interface OperatorTopology
ParentDeadException
Copyright © 2015 The Apache Software Foundation. All rights reserved.