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