org.apache.reef.wake.rx

Class AbstractRxStage<T>

java.lang.Object

org.apache.reef.wake.rx.AbstractRxStage<T>

Type Parameters:

T - type

All Implemented Interfaces:

AutoCloseable, Observer<T>, RxStage<T>, Stage

Direct Known Subclasses:

RxSyncStage, RxThreadPoolStage

public abstract class AbstractRxStage<T>
extends Object
implements RxStage<T>

An RxStage that implements metering.

Constructor Summary

Constructors

Constructor and Description
AbstractRxStage(String stageName) Constructs an abstact rxstage.

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.rx.Observer

onCompleted, onError, onNext

Methods inherited from interface java.lang.AutoCloseable

close

Constructor Detail

AbstractRxStage

public AbstractRxStage(String stageName)

Constructs an abstact rxstage.

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