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>	See AssertionSinkBuilder.assertionSink(String, SupplierEx).
AssertionSinks	Various assertions which can be used to assert items on the output of a pipeline.
LongStreamSourceP	Implements the TestSources.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.