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.