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	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

Modifier	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.