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

Packages that use Stage

Package	Description
org.apache.reef.io.network.impl	TODO: Document.
org.apache.reef.io.network.naming	TODO: Document.
org.apache.reef.wake	Public interfaces and factories for Wake's core API.
org.apache.reef.wake.examples.accumulate	A key-value combiner example.
org.apache.reef.wake.examples.join	Blocking and non-blocking join example.
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.
org.apache.reef.wake.remote.transport	Wake's remote transportation.
org.apache.reef.wake.remote.transport.netty	Netty-based remote transport implementation.
org.apache.reef.wake.rx	Wake's RX-style communication.
org.apache.reef.wake.rx.impl	Wake's RX-style communication implementation.

Uses of Stage in org.apache.reef.io.network.impl

Classes in org.apache.reef.io.network.impl that implement Stage

Modifier and Type	Class and Description
class	NetworkService<T> Network service for Task.

Uses of Stage in org.apache.reef.io.network.naming

Subinterfaces of Stage in org.apache.reef.io.network.naming

Modifier and Type	Interface and Description
interface	NameResolver NameClient interface.
interface	NameServer Naming server interface.

Classes in org.apache.reef.io.network.naming that implement Stage

Modifier and Type	Class and Description
class	LocalNameResolverImpl NameResolver looking up local name server.
class	NameClient Naming client looking up remote server.
class	NameLookupClient Naming lookup client.
class	NameRegistryClient Naming registry client.
class	NameServerImpl Naming server implementation.

Uses of Stage in org.apache.reef.wake

Subinterfaces of Stage in org.apache.reef.wake

Modifier and Type	Interface and Description
interface	EStage<T> Stage that executes an event handler.

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

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

Uses of Stage in org.apache.reef.wake.examples.accumulate

Classes in org.apache.reef.wake.examples.accumulate that implement Stage

Modifier and Type	Class and Description
class	CombinerStage<K extends Comparable<K>,V> key-value pair Combiner stage.

Uses of Stage in org.apache.reef.wake.examples.join

Classes in org.apache.reef.wake.examples.join that implement Stage

Modifier and Type	Class and Description
class	TupleSource A source class generating TupleEvent.

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

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

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	StageManager A manager that manages all the stage.
class	SyncStage<T> Stage that synchronously executes an event handler.
class	ThreadPoolStage<T> Stage that executes an event handler with a thread pool.
class	TimerStage Stage that triggers an event handler periodically.
class	WakeSharedPool This implementation uses the fork join framework to reduce the cost of spawning events in stages.

Methods in org.apache.reef.wake.impl with parameters of type Stage

Modifier and Type	Method and Description
void	StageManager.register(Stage stage)

Uses of Stage in org.apache.reef.wake.remote

Subinterfaces of Stage in org.apache.reef.wake.remote

Modifier and Type	Interface and Description
interface	RemoteManager Represents all remote connections to and from one process to another.

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

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

Modifier and Type	Class and Description
class	DefaultRemoteManagerImplementation Default remote manager implementation.
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.
class	RemoteSenderStage Stage to manage resources related to sending event remotely.

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

Subinterfaces of Stage in org.apache.reef.wake.remote.transport

Modifier and Type	Interface and Description
interface	Transport Transport for sending and receiving data.

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

Classes in org.apache.reef.wake.remote.transport.netty that implement Stage

Modifier and Type	Class and Description
class	NettyMessagingTransport Messaging transport implementation with Netty.

Uses of Stage in org.apache.reef.wake.rx

Subinterfaces of Stage in org.apache.reef.wake.rx

Modifier and Type	Interface and Description
interface	RxStage<T> Stage that executes the observer.

Classes in org.apache.reef.wake.rx that implement Stage

Modifier and Type	Class and Description
class	AbstractRxStage<T> An RxStage that implements metering.

Uses of Stage in org.apache.reef.wake.rx.impl

Classes in org.apache.reef.wake.rx.impl that implement Stage

Modifier and Type	Class and Description
class	RxSyncStage<T> Stage that executes the observer synchronously.
class	RxThreadPoolStage<T> Stage that executes the observer with a thread pool.