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