Package | Description |
---|---|
org.apache.reef.io.network.group.api.driver |
Elastic Group Communications Driver-side API Interfaces.
|
org.apache.reef.io.network.group.api.task |
Elastic Group Communications Task-side API Interfaces.
|
org.apache.reef.io.network.group.impl |
Implementations for Elastic Group Communications.
|
org.apache.reef.io.network.group.impl.driver |
This package contains the implementation of the driver side of the
Group Communication Service using the tree/flat topology.
|
org.apache.reef.io.network.group.impl.task |
Implementations for Elastic Group Communications Task-side API.
|
org.apache.reef.io.network.group.impl.utils |
Utilities for group communication.
|
org.apache.reef.io.network.proto | |
org.apache.reef.io.network.util |
Utility for REEF IO network module.
|
Modifier and Type | Method and Description |
---|---|
void |
TaskNodeStatus.expectAckFor(ReefNetworkGroupCommProtos.GroupCommMessage.Type msgType,
String srcId)
To be called before sending a ctrl msg to the task
represented by this node.
|
Modifier and Type | Method and Description |
---|---|
ReefNetworkGroupCommProtos.GroupCommMessage.Type |
GroupCommunicationMessage.getType() |
Constructor and Description |
---|
GroupCommunicationMessage(String groupName,
String operName,
ReefNetworkGroupCommProtos.GroupCommMessage.Type msgType,
String from,
int srcVersion,
String to,
int dstVersion,
byte[][] data) |
Modifier and Type | Method and Description |
---|---|
ReefNetworkGroupCommProtos.GroupCommMessage.Type |
MsgKey.getMsgType() |
Modifier and Type | Method and Description |
---|---|
void |
TaskNodeStatusImpl.expectAckFor(ReefNetworkGroupCommProtos.GroupCommMessage.Type msgType,
String srcId)
This needs to happen in line rather than in a stage because we need to note.
|
Constructor and Description |
---|
MsgKey(String src,
String dst,
ReefNetworkGroupCommProtos.GroupCommMessage.Type msgType) |
Modifier and Type | Method and Description |
---|---|
static GroupCommunicationMessage |
Utils.bldVersionedGCM(Class<? extends Name<String>> groupName,
Class<? extends Name<String>> operName,
ReefNetworkGroupCommProtos.GroupCommMessage.Type msgType,
String from,
int srcVersion,
String to,
int dstVersion,
byte[]... data) |
Modifier and Type | Method and Description |
---|---|
ReefNetworkGroupCommProtos.GroupCommMessage.Type |
ReefNetworkGroupCommProtos.GroupCommMessageOrBuilder.getType()
required .GroupCommMessage.Type type = 1; |
ReefNetworkGroupCommProtos.GroupCommMessage.Type |
ReefNetworkGroupCommProtos.GroupCommMessage.getType()
required .GroupCommMessage.Type type = 1; |
ReefNetworkGroupCommProtos.GroupCommMessage.Type |
ReefNetworkGroupCommProtos.GroupCommMessage.Builder.getType()
required .GroupCommMessage.Type type = 1; |
static ReefNetworkGroupCommProtos.GroupCommMessage.Type |
ReefNetworkGroupCommProtos.GroupCommMessage.Type.valueOf(com.google.protobuf.Descriptors.EnumValueDescriptor desc) |
static ReefNetworkGroupCommProtos.GroupCommMessage.Type |
ReefNetworkGroupCommProtos.GroupCommMessage.Type.valueOf(int value) |
static ReefNetworkGroupCommProtos.GroupCommMessage.Type |
ReefNetworkGroupCommProtos.GroupCommMessage.Type.valueOf(String name)
Returns the enum constant of this type with the specified name.
|
static ReefNetworkGroupCommProtos.GroupCommMessage.Type[] |
ReefNetworkGroupCommProtos.GroupCommMessage.Type.values()
Returns an array containing the constants of this enum type, in
the order they are declared.
|
Modifier and Type | Method and Description |
---|---|
static com.google.protobuf.Internal.EnumLiteMap<ReefNetworkGroupCommProtos.GroupCommMessage.Type> |
ReefNetworkGroupCommProtos.GroupCommMessage.Type.internalGetValueMap() |
Modifier and Type | Method and Description |
---|---|
ReefNetworkGroupCommProtos.GroupCommMessage.Builder |
ReefNetworkGroupCommProtos.GroupCommMessage.Builder.setType(ReefNetworkGroupCommProtos.GroupCommMessage.Type value)
required .GroupCommMessage.Type type = 1; |
Modifier and Type | Method and Description |
---|---|
static ReefNetworkGroupCommProtos.GroupCommMessage |
Utils.bldGCM(ReefNetworkGroupCommProtos.GroupCommMessage.Type msgType,
Identifier from,
Identifier to,
byte[]... elements) |
Copyright © 2017 The Apache Software Foundation. All rights reserved.