Uses of Class
com.hazelcast.jet.pipeline.test.AssertionSinkBuilder
Package | Description |
---|---|
com.hazelcast.jet.pipeline.test |
This package contains various mock sources to help with pipeline testing
and development.
|
-
Uses of AssertionSinkBuilder in com.hazelcast.jet.pipeline.test
Methods in com.hazelcast.jet.pipeline.test that return AssertionSinkBuilder Modifier and Type Method 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 assertionSink
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.