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 which generates events created by the
generatorFn at the specified rate infinitely. |
Copyright © 2019 Hazelcast, Inc.. All rights reserved.