Package com.hazelcast.jet.pipeline.test
This package contains various mock sources to help with pipeline testing
and development.
- Since:
- 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.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.