Package | Description |
---|---|
org.apache.reef.io.naming |
Utilities for assigning Identifiers to objects and associating socket addresses with them.
|
org.apache.reef.io.network |
TODO: Document.
|
org.apache.reef.io.network.group.api.operators |
Provides the interfaces for MPI style group communication operations.
|
org.apache.reef.io.network.group.api.task |
Elastic Group Communications Task-side API Interfaces.
|
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.operators |
Implementations for Group Communication Operators.
|
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.impl |
TODO: Document.
|
org.apache.reef.io.network.naming |
TODO: Document.
|
org.apache.reef.io.network.naming.serialization |
Contains naming serialization codecs.
|
org.apache.reef.io.network.util |
Utility for REEF IO network module.
|
org.apache.reef.wake |
Public interfaces and factories for Wake's core API.
|
org.apache.reef.wake.impl |
Wake's implementation.
|
org.apache.reef.wake.remote |
Wake's remote communication.
|
org.apache.reef.wake.remote.impl |
Implementations for Wake's remote communication.
|
Modifier and Type | Method and Description |
---|---|
Identifier |
NameAssignment.getIdentifier()
Returns an identifier of this object.
|
Modifier and Type | Method and Description |
---|---|
InetSocketAddress |
NamingLookup.lookup(Identifier id)
Lookup an Address for a given Identifier.
|
void |
NamingRegistry.register(Identifier id,
InetSocketAddress addr)
Register the given Address for the given Identifier.
|
void |
NamingRegistry.unregister(Identifier id)
Unregister the given Identifier from the registry.
|
Modifier and Type | Method and Description |
---|---|
Identifier |
ConnectionFactory.getConnectionFactoryId() |
Identifier |
Message.getDestId()
Gets a destination identifier.
|
Identifier |
ConnectionFactory.getLocalEndPointId()
Each connection factory has own local end point id.
|
Identifier |
Message.getSrcId()
Gets a source identifier.
|
Modifier and Type | Method and Description |
---|---|
<T> ConnectionFactory<T> |
NetworkConnectionService.getConnectionFactory(Identifier connectionFactoryId)
Gets an instance of ConnectionFactory which is registered by the registerConnectionFactory method.
|
Connection<T> |
ConnectionFactory.newConnection(Identifier destId)
Creates a new connection.
|
<T> ConnectionFactory<T> |
NetworkConnectionService.registerConnectionFactory(Identifier connectionFactoryId,
Codec<T> codec,
EventHandler<Message<T>> eventHandler,
LinkListener<Message<T>> linkListener,
Identifier localEndPointId)
Registers an instance of ConnectionFactory corresponding to the connectionFactoryId.
|
void |
NetworkConnectionService.unregisterConnectionFactory(Identifier connectionFactoryId)
Unregisters a connectionFactory corresponding to the connectionFactoryId
and removes the localEndPointID of the connection factory from NameServer.
|
Modifier and Type | Method and Description |
---|---|
List<T> |
ReduceScatter.apply(List<T> elements,
List<Integer> counts,
List<? extends Identifier> order)
Apply this operation on elements where counts specify the distribution of
elements to each task.
|
T |
AllReduce.apply(T element,
List<? extends Identifier> order)
Apply the operation on element.
|
List<T> |
AllGather.apply(T element,
List<? extends Identifier> order)
Apply the operation on element.
|
List<T> |
Gather.Receiver.receive(List<? extends Identifier> order)
Receive the elements sent by the senders in specified order.
|
T |
Reduce.Receiver.reduce(List<? extends Identifier> order)
Receive values sent by senders and pass them through the reduce
function in specified order.
|
void |
Scatter.Sender.send(List<T> elements,
List<? extends Identifier> order)
Distributes evenly across task ids sorted using order.
|
void |
Scatter.Sender.send(List<T> elements,
List<Integer> counts,
List<? extends Identifier> order)
Distributes as per counts across task ids sorted using order.
|
Modifier and Type | Method and Description |
---|---|
List<Identifier> |
CommunicationGroupClient.getActiveSlaveTasks() |
Modifier and Type | Method and Description |
---|---|
static Pair<TopologySimpleNode,List<Identifier>> |
TopologySerializer.decode(byte[] data,
IdentifierFactory ifac)
Recursively translate a byte array into a TopologySimpleNode and a list of task Identifiers.
|
Modifier and Type | Method and Description |
---|---|
List<T> |
GatherReceiver.receive(List<? extends Identifier> order) |
T |
ReduceReceiver.reduce(List<? extends Identifier> order) |
void |
ScatterSender.send(List<T> elements,
List<? extends Identifier> order) |
void |
ScatterSender.send(List<T> elements,
List<Integer> counts,
List<? extends Identifier> order) |
Modifier and Type | Method and Description |
---|---|
List<Identifier> |
CommunicationGroupClientImpl.getActiveSlaveTasks() |
Modifier and Type | Method and Description |
---|---|
<T> Map<String,byte[]> |
ScatterEncoder.encode(List<T> elements,
List<Integer> counts,
List<? extends Identifier> taskOrder,
Codec<T> dataCodec) |
Modifier and Type | Method and Description |
---|---|
Identifier |
NetworkService.getConnectionFactoryId() |
Identifier |
NSMessage.getDestId()
Gets a destination identifier.
|
Identifier |
NetworkService.getLocalEndPointId() |
Identifier |
NetworkService.getMyId() |
Identifier |
NSMessage.getSrcId()
Gets a source identifier.
|
Modifier and Type | Method and Description |
---|---|
<T> ConnectionFactory<T> |
NetworkConnectionServiceImpl.getConnectionFactory(Identifier connFactoryId)
Gets a ConnectionFactory.
|
Connection<T> |
NetworkService.newConnection(Identifier destId) |
<T> ConnectionFactory<T> |
NetworkConnectionServiceImpl.registerConnectionFactory(Identifier connectionFactoryId,
Codec<T> codec,
EventHandler<Message<T>> eventHandler,
LinkListener<Message<T>> linkListener,
Identifier localEndPointId) |
void |
NetworkService.registerId(Identifier id) |
void |
NetworkConnectionServiceImpl.unregisterConnectionFactory(Identifier connFactoryId) |
void |
NetworkService.unregisterId(Identifier id) |
Constructor and Description |
---|
NSMessage(Identifier srcId,
Identifier destId,
List<T> data)
Constructs a network service message.
|
NSMessage(Identifier srcId,
Identifier destId,
T data)
Constructs a network service message.
|
Modifier and Type | Method and Description |
---|---|
Identifier |
NameAssignmentTuple.getIdentifier()
Gets an identifier.
|
Modifier and Type | Method and Description |
---|---|
InetSocketAddress |
NameCache.get(Identifier key,
Callable<InetSocketAddress> valueFetcher)
Gets an address for an identifier.
|
void |
NameCache.invalidate(Identifier key)
Invalidates the entry for an identifier.
|
InetSocketAddress |
NameServerImpl.lookup(Identifier id)
Finds an address for an identifier locally.
|
InetSocketAddress |
NameServer.lookup(Identifier id)
Finds an address for an identifier locally.
|
InetSocketAddress |
NameLookupClient.lookup(Identifier id)
Finds an address for an identifier.
|
InetSocketAddress |
NameClient.lookup(Identifier id)
Finds an address for an identifier.
|
InetSocketAddress |
LocalNameResolverImpl.lookup(Identifier id) |
void |
NameServerImpl.register(Identifier id,
InetSocketAddress addr)
Registers an (identifier, address) mapping locally.
|
void |
NameServer.register(Identifier id,
InetSocketAddress addr)
Registers an (identifier, address) mapping locally.
|
void |
NameRegistryClient.register(Identifier id,
InetSocketAddress addr)
Registers an (identifier, address) mapping.
|
void |
NameClient.register(Identifier id,
InetSocketAddress addr)
Registers an (identifier, address) mapping.
|
void |
LocalNameResolverImpl.register(Identifier id,
InetSocketAddress address) |
InetSocketAddress |
NameLookupClient.remoteLookup(Identifier id)
Retrieves an address for an identifier remotely.
|
InetSocketAddress |
NameClient.remoteLookup(Identifier id)
Retrieves an address for an identifier remotely.
|
void |
NameServerImpl.unregister(Identifier id)
Unregisters an identifier locally.
|
void |
NameServer.unregister(Identifier id)
Unregisters an identifier locally.
|
void |
NameRegistryClient.unregister(Identifier id)
Unregisters an identifier.
|
void |
NameClient.unregister(Identifier id)
Unregisters an identifier.
|
void |
LocalNameResolverImpl.unregister(Identifier id) |
Modifier and Type | Method and Description |
---|---|
List<NameAssignment> |
NameServerImpl.lookup(Iterable<Identifier> identifiers)
Finds addresses for identifiers locally.
|
List<NameAssignment> |
NameServer.lookup(Iterable<Identifier> identifiers)
Finds addresses for identifiers locally.
|
Constructor and Description |
---|
NameAssignmentTuple(Identifier id,
InetSocketAddress addr)
Constructs a name assignment tuple.
|
Modifier and Type | Method and Description |
---|---|
Identifier |
NamingUnregisterRequest.getIdentifier()
Gets an identifier.
|
Modifier and Type | Method and Description |
---|---|
Iterable<Identifier> |
NamingLookupRequest.getIdentifiers()
Gets identifiers.
|
Constructor and Description |
---|
NamingUnregisterRequest(Identifier id)
Constructs a naming un-registration request.
|
Constructor and Description |
---|
NamingLookupRequest(Iterable<Identifier> ids)
Constructs a naming lookup request.
|
Modifier and Type | Class and Description |
---|---|
class |
StringIdentifier
String identifier.
|
Modifier and Type | Method and Description |
---|---|
static <T extends Identifier> |
Utils.parseList(String ids,
IdentifierFactory factory)
Parse a string of multiple IDs.
|
Modifier and Type | Method and Description |
---|---|
Identifier |
StringIdentifierFactory.getNewInstance(String s)
Creates a StringIdentifier object.
|
Modifier and Type | Method and Description |
---|---|
static ReefNetworkGroupCommProtos.GroupCommMessage |
Utils.bldGCM(ReefNetworkGroupCommProtos.GroupCommMessage.Type msgType,
Identifier from,
Identifier to,
byte[]... elements) |
int |
StringIdentifier.compareTo(Identifier o) |
Modifier and Type | Interface and Description |
---|---|
interface |
ComparableIdentifier
Identifier that can be totally ordered.
|
Modifier and Type | Method and Description |
---|---|
Identifier |
Identifiable.getId()
Returns an identifier of this object.
|
Identifier |
IdentifierFactory.getNewInstance(String str)
Creates a RemoteIdentifier object.
|
Modifier and Type | Method and Description |
---|---|
Identifier |
DefaultIdentifierFactory.getNewInstance(String str)
Creates a new remote identifier instance.
|
Constructor and Description |
---|
DefaultIdentifierFactory(Map<String,Class<? extends Identifier>> typeToClazzMap)
Constructs a default remote identifier factory.
|
Modifier and Type | Interface and Description |
---|---|
interface |
RemoteIdentifier
Wake remote identifier.
|
Modifier and Type | Class and Description |
---|---|
class |
SocketRemoteIdentifier
Remote identifier based on a socket address.
|
Copyright © 2017 The Apache Software Foundation. All rights reserved.