org.apache.reef.wake

Class AbstractEStage<T>

java.lang.Object

org.apache.reef.wake.AbstractEStage<T>

Type Parameters:

T - type

All Implemented Interfaces:

AutoCloseable, EStage<T>, EventHandler<T>, Stage

Direct Known Subclasses:

ForkPoolStage, IndependentIterationsThreadPoolStage, SingleThreadStage, SyncStage, ThreadPoolStage

public abstract class AbstractEStage<T>
extends Object
implements EStage<T>

An EStage that implements metering.

Constructor Summary

Constructors

Constructor and Description
AbstractEStage(String stageName) Constructs an abstract estage.

Method Summary

Methods

Modifier and Type	Method and Description
Meter	getInMeter() Gets the input meter of this stage.
Meter	getOutMeter() Gets the output meter of this stage.
boolean	isClosed() Check if the stage can still accept messages.
String	toString() Get human readable representation of the class (used for logging).

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface org.apache.reef.wake.EventHandler

onNext

Methods inherited from interface java.lang.AutoCloseable

close

Constructor Detail

AbstractEStage

public AbstractEStage(String stageName)

Constructs an abstract estage.

Parameters:

stageName - the stage name

Method Detail

getInMeter

public Meter getInMeter()

Gets the input meter of this stage.

Returns:

the input meter

getOutMeter

public Meter getOutMeter()

Gets the output meter of this stage.

Returns:

the output meter

isClosed

public boolean isClosed()

Check if the stage can still accept messages.

Returns:

true if the stage is closed, false otherwise.

toString

public String toString()

Get human readable representation of the class (used for logging).

Overrides:

toString in class Object

Returns:

A string that contains stage name.