Package com.hazelcast.jet.pipeline.test
This package contains various mock sources to help with pipeline testing
and development.
- Since:
- Jet 3.2
-
Interface Summary Interface Description GeneratorFunction<R> A function which takes a timestamp and a sequence number as the input. -
Class Summary Class Description Assertions Various assertions which can be used to assert items passing through the pipeline for correctness.AssertionSinkBuilder<S,T> AssertionSinks Various assertions which can be used to assert items on the output of a pipeline.LongStreamSourceP Implements theTestSources.longStream(long, long)
source.ParallelBatchP<T> Implements a mock batch source with parallelism.ParallelStreamP<T> Implements a mock stream source with parallelism.SimpleEvent A simple event with a timestamp and a sequence number.TestSources Contains factory methods for various mock sources which can be used for pipeline testing and development. -
Exception Summary Exception Description AssertionCompletedException An exception which indicates that an assertion passed successfully.