Package | Description |
---|---|
org.apache.reef.io.network.group.api.driver |
Elastic Group Communications Driver-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.wake |
Public interfaces and factories for Wake's core API.
|
org.apache.reef.wake.impl |
Wake's implementation.
|
org.apache.reef.wake.remote.impl |
Implementations for Wake's remote communication.
|
org.apache.reef.wake.remote.transport |
Wake's remote transportation.
|
org.apache.reef.wake.remote.transport.netty |
Netty-based remote transport implementation.
|
Modifier and Type | Method and Description |
---|---|
EStage<FailedEvaluator> |
GroupCommServiceDriver.getGroupCommFailedEvaluatorStage()
Not user facing but used the Group Communication Service class.
|
EStage<FailedTask> |
GroupCommServiceDriver.getGroupCommFailedTaskStage()
Not user facing but used the Group Communication Service class.
|
EStage<RunningTask> |
GroupCommServiceDriver.getGroupCommRunningTaskStage()
Not user facing but used the Group Communication Service class.
|
Modifier and Type | Method and Description |
---|---|
EStage<FailedEvaluator> |
GroupCommDriverImpl.getGroupCommFailedEvaluatorStage() |
EStage<FailedTask> |
GroupCommDriverImpl.getGroupCommFailedTaskStage() |
EStage<RunningTask> |
GroupCommDriverImpl.getGroupCommRunningTaskStage() |
Constructor and Description |
---|
CommunicationGroupDriverImpl(Class<? extends Name<String>> groupName,
ConfigurationSerializer confSerializer,
EStage<GroupCommunicationMessage> senderStage,
BroadcastingEventHandler<RunningTask> groupCommRunningTaskHandler,
BroadcastingEventHandler<FailedTask> groupCommFailedTaskHandler,
BroadcastingEventHandler<FailedEvaluator> groupCommFailedEvaluatorHandler,
BroadcastingEventHandler<GroupCommunicationMessage> commGroupMessageHandler,
String driverId,
int numberOfTasks,
int fanOut)
Deprecated.
in 0.14. Use Tang to obtain an instance of this instead.
|
TaskNodeImpl(EStage<GroupCommunicationMessage> senderStage,
Class<? extends Name<String>> groupName,
Class<? extends Name<String>> operatorName,
String taskId,
String driverId,
boolean isRoot) |
TopologyUpdateWaitHandler(EStage<GroupCommunicationMessage> senderStage,
Class<? extends Name<String>> groupName,
Class<? extends Name<String>> operName,
String driverId,
int driverVersion,
String dstId,
int dstVersion,
String qualifiedName,
byte[] data)
The handler will wait for all nodes to acquire topoLock
and send TopologySetup msg.
|
Modifier and Type | Class and Description |
---|---|
class |
AbstractEStage<T>
An
EStage that implements metering. |
Modifier and Type | Class and Description |
---|---|
class |
ForkPoolStage<T>
This Wake event handling stage uses a
ForkJoinPool
to submit tasks. |
class |
IndependentIterationsThreadPoolStage<T>
This stage uses a thread pool to schedule events in parallel.
|
class |
SingleThreadStage<T>
Single thread stage that runs the event handler.
|
class |
SyncStage<T>
Stage that synchronously executes an event handler.
|
class |
ThreadPoolStage<T>
Stage that executes an event handler with a thread pool.
|
Modifier and Type | Class and Description |
---|---|
class |
DefaultTransportEStage
A default event-based message transporting stage for both client and server.
|
class |
OrderedRemoteReceiverStage
Receive incoming events and dispatch to correct handlers in order.
|
class |
RemoteReceiverStage
Receive incoming events and dispatch to correct handlers.
|
Modifier and Type | Method and Description |
---|---|
Transport |
TransportFactory.newInstance(String hostAddress,
int port,
EStage<TransportEvent> clientStage,
EStage<TransportEvent> serverStage,
int numberOfTries,
int retryTimeout)
Creates a transport.
|
Transport |
TransportFactory.newInstance(String hostAddress,
int port,
EStage<TransportEvent> clientStage,
EStage<TransportEvent> serverStage,
int numberOfTries,
int retryTimeout)
Creates a transport.
|
Transport |
TransportFactory.newInstance(String hostAddress,
int port,
EStage<TransportEvent> clientStage,
EStage<TransportEvent> serverStage,
int numberOfTries,
int retryTimeout,
TcpPortProvider tcpPortProvider)
Creates a transport.
|
Transport |
TransportFactory.newInstance(String hostAddress,
int port,
EStage<TransportEvent> clientStage,
EStage<TransportEvent> serverStage,
int numberOfTries,
int retryTimeout,
TcpPortProvider tcpPortProvider)
Creates a transport.
|
Modifier and Type | Method and Description |
---|---|
Transport |
MessagingTransportFactory.newInstance(String hostAddress,
int port,
EStage<TransportEvent> clientStage,
EStage<TransportEvent> serverStage,
int numberOfTries,
int retryTimeout)
Creates a transport.
|
Transport |
MessagingTransportFactory.newInstance(String hostAddress,
int port,
EStage<TransportEvent> clientStage,
EStage<TransportEvent> serverStage,
int numberOfTries,
int retryTimeout)
Creates a transport.
|
Transport |
MessagingTransportFactory.newInstance(String hostAddress,
int port,
EStage<TransportEvent> clientStage,
EStage<TransportEvent> serverStage,
int numberOfTries,
int retryTimeout,
TcpPortProvider tcpPortProvider)
Creates a transport.
|
Transport |
MessagingTransportFactory.newInstance(String hostAddress,
int port,
EStage<TransportEvent> clientStage,
EStage<TransportEvent> serverStage,
int numberOfTries,
int retryTimeout,
TcpPortProvider tcpPortProvider)
Creates a transport.
|
Copyright © 2017 The Apache Software Foundation. All rights reserved.