See: Description
Class | Description |
---|---|
ByteArray2String | |
Cache<T> | |
CipherStage | |
Clock |
This stage sends the current timestamp repeatedly with a given interval delay of
Clock.intervalDelayInMs . |
CollectorSink<T> | |
Counter<T> | |
CountingMapMerger<T> |
Receives different CountingMap instances and merges them into a single one.
|
ElementDelayMeasuringStage<T> | |
ElementsToList<I> | |
ElementThroughputMeasuringStage<T> | |
EveryXthStage<T> | |
FileExtensionSwitch | |
InitialElementProducer<T> |
Represents a producer stage which outputs all of its elements in the first and only execution.
|
InputPortSizePrinter<T> | |
InstanceCounter<T,C extends T> | |
InstanceOfFilter<I,O extends I> | |
MappingCounter<T> |
This counts how many of different elements are sent to this stage.
|
MD5Stage | |
MultipleInstanceOfFilter<I> | |
NoopFilter<T> | |
ObjectProducer<T> | Deprecated
since 3.0.
|
Ramp |
Sends a sequence of numbers starting from 0 to the value 'n' (not included) received by the input port, i.e., (0,1,2,..,n-1).
|
RandomIntegerGenerator | |
Relay<T> | |
ResponsiveProducer<T> |
Represents a producer stage which outputs one element per execution.
|
StartTimestampFilter | |
StatelessCounter<T> | |
StopTimestampFilter | |
StreamProducer<T> | |
ZipByteArray |
A stage to compress and decompress byte arrays
|
Enum | Description |
---|---|
CipherStage.CipherMode | |
ZipByteArray.ZipMode |
Copyright © 2015–2020. All rights reserved.