BroadcastReceiver(String groupName,
String operName,
String selfId,
Codec<T> dataCodec,
String driverId,
int version,
CommGroupNetworkHandler commGroupNetworkHandler,
NetworkService<GroupCommunicationMessage> netService,
CommunicationGroupServiceClient commGroupClient) |
BroadcastSender(String groupName,
String operName,
String selfId,
Codec<T> dataCodec,
String driverId,
int version,
CommGroupNetworkHandler commGroupNetworkHandler,
NetworkService<GroupCommunicationMessage> netService,
CommunicationGroupServiceClient commGroupClient) |
GatherReceiver(String groupName,
String operName,
String selfId,
Codec<T> dataCodec,
String driverId,
int version,
CommGroupNetworkHandler commGroupNetworkHandler,
NetworkService<GroupCommunicationMessage> netService,
CommunicationGroupServiceClient commGroupClient) |
GatherSender(String groupName,
String operName,
String selfId,
Codec<T> dataCodec,
String driverId,
int version,
CommGroupNetworkHandler commGroupNetworkHandler,
NetworkService<GroupCommunicationMessage> netService,
CommunicationGroupServiceClient commGroupClient) |
ReduceReceiver(String groupName,
String operName,
String selfId,
Codec<T> dataCodec,
Reduce.ReduceFunction<T> reduceFunction,
String driverId,
int version,
CommGroupNetworkHandler commGroupNetworkHandler,
NetworkService<GroupCommunicationMessage> netService,
CommunicationGroupServiceClient commGroupClient) |
ReduceSender(String groupName,
String operName,
String selfId,
Codec<T> dataCodec,
Reduce.ReduceFunction<T> reduceFunction,
String driverId,
int version,
CommGroupNetworkHandler commGroupNetworkHandler,
NetworkService<GroupCommunicationMessage> netService,
CommunicationGroupServiceClient commGroupClient) |
ScatterReceiver(String groupName,
String operName,
String selfId,
Codec<T> dataCodec,
String driverId,
int version,
CommGroupNetworkHandler commGroupNetworkHandler,
NetworkService<GroupCommunicationMessage> netService,
CommunicationGroupServiceClient commGroupClient,
ScatterDecoder scatterDecoder) |
ScatterSender(String groupName,
String operName,
String selfId,
Codec<T> dataCodec,
String driverId,
int version,
CommGroupNetworkHandler commGroupNetworkHandler,
NetworkService<GroupCommunicationMessage> netService,
CommunicationGroupServiceClient commGroupClient,
ScatterEncoder scatterEncoder) |