A function which takes a timestamp and a sequence number as the input.
Various assertions which can be used to assert items passing through the pipeline for correctness.
Various assertions which can be used to assert items on the output of a pipeline.
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.
An exception which indicates that an assertion passed successfully.
Copyright © 2021 Hazelcast, Inc.. All rights reserved.