Package | Description |
---|---|
com.hazelcast.jet.pipeline.test |
This package contains various mock sources to help with pipeline testing
and development.
|
Modifier and Type | Method and Description |
---|---|
static <S> AssertionSinkBuilder<S,Void> |
AssertionSinkBuilder.assertionSink(String name,
SupplierEx<? extends S> createFn)
Returns a builder object that offers a step-by-step fluent API to build
an assertion
Sink for the Pipeline API. |
AssertionSinkBuilder<S,T> |
AssertionSinkBuilder.completeFn(ConsumerEx<? super S> completeFn)
Sets the function that will be called after all the upstream stages have
completed and all the items were received.
|
<T_NEW> AssertionSinkBuilder<S,T_NEW> |
AssertionSinkBuilder.receiveFn(BiConsumerEx<? super S,? super T_NEW> receiveFn)
Sets the function Jet will call upon receiving every item.
|
AssertionSinkBuilder<S,T> |
AssertionSinkBuilder.timerFn(ConsumerEx<? super S> timerFn)
Sets the function that will be called periodically.
|
Copyright © 2023 Hazelcast, Inc.. All rights reserved.