| Package | Description |
|---|---|
| com.hazelcast.jet.pipeline.test |
This package contains various mock sources to help with pipeline testing
and development.
|
| Modifier and Type | Class and Description |
|---|---|
class |
LongStreamSourceP
Implements the
TestSources.longStream(long, long) source. |
class |
ParallelBatchP<T>
Implements a mock batch source with parallelism.
|
class |
ParallelStreamP<T>
Implements a mock stream source with parallelism.
|
Copyright © 2022 Hazelcast, Inc.. All rights reserved.