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 © 2021 Hazelcast, Inc.. All rights reserved.