Uses of Interface
com.hazelcast.jet.pipeline.test.GeneratorFunction

Packages that use 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 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 parameters in com.hazelcast.jet.pipeline.test with type arguments of type GeneratorFunction

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.