This package contains various mock sources to help with pipeline testing and development.
Interface Summary Interface Description GeneratorFunction<R>A function which takes a timestamp and a sequence number as the input.
Class Summary Class Description AssertionsVarious assertions which can be used to assert items passing through the pipeline for correctness. AssertionSinkBuilder<S,T> AssertionSinksVarious assertions which can be used to assert items on the output of a pipeline. LongStreamSourcePImplements the
ParallelBatchP<T>Implements a mock batch source with parallelism. ParallelStreamP<T>Implements a mock stream source with parallelism. SimpleEventA simple event with a timestamp and a sequence number. TestSourcesContains factory methods for various mock sources which can be used for pipeline testing and development.
Exception Summary Exception Description AssertionCompletedExceptionAn exception which indicates that an assertion passed successfully.