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.

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, 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