Uses of Interface
org.apache.reef.wake.EStage

Packages that use EStage

Package	Description
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.

Uses of EStage in org.apache.reef.wake

Classes in org.apache.reef.wake that implement EStage

Modifier and Type	Class and Description
class	AbstractEStage<T> An EStage that implements metering.

Uses of EStage in org.apache.reef.wake.impl

Classes in org.apache.reef.wake.impl that implement EStage

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.

Uses of EStage in org.apache.reef.wake.remote.impl

Classes in org.apache.reef.wake.remote.impl that implement EStage

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.

Uses of EStage in org.apache.reef.wake.remote.transport

Methods in org.apache.reef.wake.remote.transport with parameters of type EStage

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.

Uses of EStage in org.apache.reef.wake.remote.transport.netty

Methods in org.apache.reef.wake.remote.transport.netty with parameters of type EStage

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.