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.