public final class EveryXthPrinter<T> extends CompositeStage
DEFAULT_PIPE_CAPACITY
Constructor and Description |
---|
EveryXthPrinter(int threshold) |
Modifier and Type | Method and Description |
---|---|
AbstractStage |
getFirstStage() |
InputPort<T> |
getInputPort() |
OutputPort<T> |
getNewOutputPort() |
connectPorts, connectPorts, createInputPort, createOutputPort
public OutputPort<T> getNewOutputPort()
public AbstractStage getFirstStage()
Copyright © 2015–2020. All rights reserved.