Package | Description |
---|---|
org.apache.reef.io.network.group.impl.task |
Implementations for Elastic Group Communications Task-side API.
|
org.apache.reef.io.network.proto | |
org.apache.reef.io.network.util |
Utility for REEF IO network module.
|
Constructor and Description |
---|
GroupCommClientImpl(Set<String> groupConfigs,
String taskId,
GroupCommNetworkHandler groupCommNetworkHandler,
NetworkService<ReefNetworkGroupCommProtos.GroupCommMessage> netService,
ConfigurationSerializer configSerializer)
Deprecated.
in 0.14.
Use the other constructor that receives an
injector as a parameter instead.
The parameters taskId and netService can be removed from the other constructor when
this constructor gets deleted. |
Modifier and Type | Field and Description |
---|---|
static com.google.protobuf.Parser<ReefNetworkGroupCommProtos.GroupCommMessage> |
ReefNetworkGroupCommProtos.GroupCommMessage.PARSER |
Modifier and Type | Method and Description |
---|---|
ReefNetworkGroupCommProtos.GroupCommMessage |
ReefNetworkGroupCommProtos.GroupCommMessage.Builder.build() |
ReefNetworkGroupCommProtos.GroupCommMessage |
ReefNetworkGroupCommProtos.GroupCommMessage.Builder.buildPartial() |
static ReefNetworkGroupCommProtos.GroupCommMessage |
ReefNetworkGroupCommProtos.GroupCommMessage.getDefaultInstance() |
ReefNetworkGroupCommProtos.GroupCommMessage |
ReefNetworkGroupCommProtos.GroupCommMessage.getDefaultInstanceForType() |
ReefNetworkGroupCommProtos.GroupCommMessage |
ReefNetworkGroupCommProtos.GroupCommMessage.Builder.getDefaultInstanceForType() |
static ReefNetworkGroupCommProtos.GroupCommMessage |
ReefNetworkGroupCommProtos.GroupCommMessage.parseDelimitedFrom(InputStream input) |
static ReefNetworkGroupCommProtos.GroupCommMessage |
ReefNetworkGroupCommProtos.GroupCommMessage.parseDelimitedFrom(InputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static ReefNetworkGroupCommProtos.GroupCommMessage |
ReefNetworkGroupCommProtos.GroupCommMessage.parseFrom(byte[] data) |
static ReefNetworkGroupCommProtos.GroupCommMessage |
ReefNetworkGroupCommProtos.GroupCommMessage.parseFrom(byte[] data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static ReefNetworkGroupCommProtos.GroupCommMessage |
ReefNetworkGroupCommProtos.GroupCommMessage.parseFrom(com.google.protobuf.ByteString data) |
static ReefNetworkGroupCommProtos.GroupCommMessage |
ReefNetworkGroupCommProtos.GroupCommMessage.parseFrom(com.google.protobuf.ByteString data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static ReefNetworkGroupCommProtos.GroupCommMessage |
ReefNetworkGroupCommProtos.GroupCommMessage.parseFrom(com.google.protobuf.CodedInputStream input) |
static ReefNetworkGroupCommProtos.GroupCommMessage |
ReefNetworkGroupCommProtos.GroupCommMessage.parseFrom(com.google.protobuf.CodedInputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static ReefNetworkGroupCommProtos.GroupCommMessage |
ReefNetworkGroupCommProtos.GroupCommMessage.parseFrom(InputStream input) |
static ReefNetworkGroupCommProtos.GroupCommMessage |
ReefNetworkGroupCommProtos.GroupCommMessage.parseFrom(InputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
Modifier and Type | Method and Description |
---|---|
com.google.protobuf.Parser<ReefNetworkGroupCommProtos.GroupCommMessage> |
ReefNetworkGroupCommProtos.GroupCommMessage.getParserForType() |
Modifier and Type | Method and Description |
---|---|
ReefNetworkGroupCommProtos.GroupCommMessage.Builder |
ReefNetworkGroupCommProtos.GroupCommMessage.Builder.mergeFrom(ReefNetworkGroupCommProtos.GroupCommMessage other) |
static ReefNetworkGroupCommProtos.GroupCommMessage.Builder |
ReefNetworkGroupCommProtos.GroupCommMessage.newBuilder(ReefNetworkGroupCommProtos.GroupCommMessage prototype) |
Modifier and Type | Method and Description |
---|---|
static ReefNetworkGroupCommProtos.GroupCommMessage |
Utils.bldGCM(ReefNetworkGroupCommProtos.GroupCommMessage.Type msgType,
Identifier from,
Identifier to,
byte[]... elements) |
Copyright © 2016 The Apache Software Foundation. All rights reserved.