See: Description
Interface | Description |
---|---|
GeneratorFunction<R> |
A function which takes a timestamp and a sequence number as the input.
|
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 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 | Description |
---|---|
AssertionCompletedException |
An exception which indicates that an assertion passed successfully.
|
Copyright © 2022 Hazelcast, Inc.. All rights reserved.