Package | Description |
---|---|
com.hazelcast.jet.pipeline.test |
This package contains various mock sources to help with pipeline testing
and development.
|
Modifier and Type | Method and Description |
---|---|
static <T> StreamSource<T> |
TestSources.itemStream(int itemsPerSecond,
GeneratorFunction<? extends T> generatorFn)
Returns a streaming source that generates events created by the
generatorFn at the specified rate. |
Constructor and Description |
---|
ParallelStreamP(long eventsPerSecondPerGenerator,
EventTimePolicy<? super T> eventTimePolicy,
List<? extends GeneratorFunction<T>> generators)
Creates a processor that generates items using its assigned
generator functions.
|
Copyright © 2023 Hazelcast, Inc.. All rights reserved.