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