T
- typepublic abstract class AbstractEStage<T> extends Object implements EStage<T>
EStage
that implements metering.Constructor and Description |
---|
AbstractEStage(String stageName)
Constructs an abstract estage.
|
Modifier and Type | Method and Description |
---|---|
Meter |
getInMeter()
Gets the input meter of this stage.
|
Meter |
getOutMeter()
Gets the output meter of this stage.
|
equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
onNext
close
public AbstractEStage(String stageName)
stageName
- the stage namepublic Meter getInMeter()
public Meter getOutMeter()
Copyright © 2016 The Apache Software Foundation. All rights reserved.