public final class StopTimestampFilter extends AbstractFilter<TimestampObject>
outputPort
inputPort
logger
Constructor and Description |
---|
StopTimestampFilter() |
Modifier and Type | Method and Description |
---|---|
protected void |
execute(TimestampObject element)
Contains the logic of this stage and is invoked (possibly multiple times) by the framework.
|
getOutputPort
createInputPort, execute, getInputPort
abort, addInputPortRemovedListener, addOutputPortRemovedListener, compareAndSetBeingExecuted, createInputPort, createInputPort, createInputPort, createOutputPort, createOutputPort, createOutputPort, createOutputPort, declareActive, declarePassive, executeByFramework, getCurrentState, getId, getInputPorts, getOutputPorts, getOwningThread, getTerminationStrategy, isActive, isBeingExecuted, isPaused, isProducer, isStateless, onSignal, onStarting, onTerminating, onValidating, removeDynamicPort, removeDynamicPort, setPaused, setStateless, shouldBeTerminated, signalAlreadyReceived, terminateStage, toString, workCompleted
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
getInputPort
protected void execute(TimestampObject element)
AbstractConsumerStage
execute
in class AbstractConsumerStage<TimestampObject>
element
- the next non-null element from the (only) input port of this stageCopyright © 2015–2020. All rights reserved.