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 StreamSource<SimpleEvent> |
TestSources.itemStream(int itemsPerSecond)
Returns a streaming source that generates events of type
SimpleEvent at the specified rate. |
Copyright © 2021 Hazelcast, Inc.. All rights reserved.