Uses of Class
com.hazelcast.jet.core.AbstractProcessor
Package | Description |
---|---|
com.hazelcast.jet.pipeline.test |
This package contains various mock sources to help with pipeline testing
and development.
|
-
Uses of AbstractProcessor in com.hazelcast.jet.pipeline.test
Subclasses of AbstractProcessor in com.hazelcast.jet.pipeline.test Modifier and Type Class Description class
LongStreamSourceP
Implements theTestSources.longStream(long, long)
source.class
ParallelBatchP<T>
Implements a mock batch source with parallelism.class
ParallelStreamP<T>
Implements a mock stream source with parallelism.