Modifier and Type | Method and Description |
---|---|
static <T> BatchSource<T> |
items(Iterable<? extends T> items)
Returns a batch source which iterates through the supplied iterable and then
terminates.
|
static <T> BatchSource<T> |
items(T... items)
Returns a batch source which iterates through the supplied items and then
terminates.
|
static StreamSource<SimpleEvent> |
itemStream(int itemsPerSecond)
Returns a streaming source which generates events of type
SimpleEvent at
the specified rate infinitely. |
static <T> StreamSource<T> |
itemStream(int itemsPerSecond,
GeneratorFunction<? extends T> generatorFn)
Returns a streaming source which generates events created by the
generatorFn at the specified rate infinitely. |
@Nonnull public static <T> BatchSource<T> items(@Nonnull Iterable<? extends T> items)
@Nonnull public static <T> BatchSource<T> items(@Nonnull T... items)
@Nonnull public static StreamSource<SimpleEvent> itemStream(int itemsPerSecond)
SimpleEvent
at
the specified rate infinitely.
This source is not fault-tolerant. The sequence will be reset once a job is restarted. The source supports native timestamps. The timestamp is the current system time at the moment they are generated.
Note: There is no absolute guarantee that the actual rate of emitted items will match the supplied value. It is done on a best-effort basis.
itemsPerSecond
- how many items should be emitted each second@Nonnull public static <T> StreamSource<T> itemStream(int itemsPerSecond, @Nonnull GeneratorFunction<? extends T> generatorFn)
generatorFn
at the specified rate infinitely.
This source is not fault-tolerant. The sequence will be reset once a job is restarted. The source supports native timestamps. The timestamp is the current system time at the moment they are generated.
Note: There is no absolute guarantee that the actual rate of emitted items will match the supplied value. It is done on a best-effort basis.
itemsPerSecond
- how many items should be emitted each secondgeneratorFn
- a function which takes the timestamp and the sequence of the generated
item and maps it to the desired typeCopyright © 2019 Hazelcast, Inc.. All rights reserved.