Uses of Interface
com.hazelcast.jet.pipeline.BatchStage
Package
Description
The Pipeline API is Jet's high-level API to build and execute
distributed computation jobs.
This package contains various mock sources to help with pipeline testing
and development.
Contributes a
PythonTransforms.mapUsingPython(com.hazelcast.jet.python.PythonServiceConfig)
transform that allows you to transform Jet pipeline data using a Python
function.-
Uses of BatchStage in com.hazelcast.jet.pipeline
Modifier and TypeMethodDescription<R> BatchStage<R>
BatchStage.aggregate
(AggregateOperation1<? super T, ?, ? extends R> aggrOp) Attaches a stage that performs the given aggregate operation over all the items it receives.<R> BatchStage<Map.Entry<K,
R>> BatchStageWithKey.aggregate
(AggregateOperation1<? super T, ?, ? extends R> aggrOp) Attaches a stage that performs the given group-and-aggregate operation.default <T1,
R0, R1> BatchStage<Tuple2<R0, R1>> BatchStage.aggregate2
(AggregateOperation1<? super T, ?, ? extends R0> aggrOp0, BatchStage<T1> stage1, AggregateOperation1<? super T1, ?, ? extends R1> aggrOp1) Attaches a stage that co-aggregates the data from this and the supplied stage by performing a separate aggregate operation on each and emits a singleTuple2
with their results.<T1,
R> BatchStage<R> BatchStage.aggregate2
(BatchStage<T1> stage1, AggregateOperation2<? super T, ? super T1, ?, ? extends R> aggrOp) Attaches a stage that performs the given aggregate operation over all the items it receives from both this stage andstage1
you supply.default <T1,
R0, R1> BatchStage<Map.Entry<K, Tuple2<R0, R1>>> BatchStageWithKey.aggregate2
(AggregateOperation1<? super T, ?, ? extends R0> aggrOp0, BatchStageWithKey<? extends T1, ? extends K> stage1, AggregateOperation1<? super T1, ?, ? extends R1> aggrOp1) Attaches a stage that performs the given cogroup-and-aggregate transformation of the items from both this stage andstage1
you supply.<T1,
R> BatchStage<Map.Entry<K, R>> BatchStageWithKey.aggregate2
(BatchStageWithKey<T1, ? extends K> stage1, AggregateOperation2<? super T, ? super T1, ?, R> aggrOp) Attaches a stage that performs the given cogroup-and-aggregate operation over the items from both this stage andstage1
you supply.default <T1,
T2, R0, R1, R2>
BatchStage<Tuple3<R0,R1, R2>> BatchStage.aggregate3
(AggregateOperation1<? super T, ?, ? extends R0> aggrOp0, BatchStage<T1> stage1, AggregateOperation1<? super T1, ?, ? extends R1> aggrOp1, BatchStage<T2> stage2, AggregateOperation1<? super T2, ?, ? extends R2> aggrOp2) Attaches a stage that co-aggregates the data from this and the two supplied stages by performing a separate aggregate operation on each and emits a singleTuple3
with their results.<T1,
T2, R> BatchStage<R> BatchStage.aggregate3
(BatchStage<T1> stage1, BatchStage<T2> stage2, AggregateOperation3<? super T, ? super T1, ? super T2, ?, ? extends R> aggrOp) Attaches a stage that performs the given aggregate operation over all the items it receives from this stage as well asstage1
andstage2
you supply.default <T1,
T2, R0, R1, R2>
BatchStage<Map.Entry<K,Tuple3<R0, R1, R2>>> BatchStageWithKey.aggregate3
(AggregateOperation1<? super T, ?, ? extends R0> aggrOp0, BatchStageWithKey<T1, ? extends K> stage1, AggregateOperation1<? super T1, ?, ? extends R1> aggrOp1, BatchStageWithKey<T2, ? extends K> stage2, AggregateOperation1<? super T2, ?, ? extends R2> aggrOp2) Attaches a stage that performs the given cogroup-and-aggregate transformation of the items from this stage as well asstage1
andstage2
you supply.<T1,
T2, R> BatchStage<Map.Entry<K, R>> BatchStageWithKey.aggregate3
(BatchStageWithKey<T1, ? extends K> stage1, BatchStageWithKey<T2, ? extends K> stage2, AggregateOperation3<? super T, ? super T1, ? super T2, ?, ? extends R> aggrOp) Attaches a stage that performs the given cogroup-and-aggregate operation over the items from this stage as well asstage1
andstage2
you supply.default <R> BatchStage<R>
BatchStage.apply
(FunctionEx<? super BatchStage<T>, ? extends BatchStage<R>> transformFn) Transformsthis
stage using the providedtransformFn
and returns the transformed stage.AggregateBuilder.build()
Creates and returns a pipeline stage that performs the co-aggregation of the stages registered with this builder object.<R> BatchStage<R>
AggregateBuilder.build
(FunctionEx<? super ItemsByTag, ? extends R> finishFn) Creates and returns a pipeline stage that performs the co-aggregation of the stages registered with this builder object.<R> BatchStage<R>
AggregateBuilder1.build
(AggregateOperation<?, R> aggrOp) Creates and returns a pipeline stage that performs the co-aggregation of pipeline stages registered with this builder object.GroupAggregateBuilder.build()
Creates and returns a pipeline stage that performs the co-aggregation of the stages registered with this builder object and emits aMap.Entry(key, resultsByTag)
for each distinct key.<R> BatchStage<Map.Entry<K,
R>> GroupAggregateBuilder1.build
(AggregateOperation<?, R> aggrOp) Creates and returns a pipeline stage that performs the co-grouping and aggregation of pipeline stages registered with this builder object.<R,
OUT> BatchStage<OUT> GroupAggregateBuilder1.build
(AggregateOperation<?, R> aggrOp, BiFunctionEx<? super K, ? super R, OUT> mapToOutputFn) Deprecated.This is a leftover from an earlier development cycle of the Pipeline API.<R> BatchStage<R>
HashJoinBuilder.build
(BiFunctionEx<T0, ItemsByTag, R> mapToOutputFn) Builds a new pipeline stage that performs the hash-join operation.default <R> BatchStage<R>
BatchStage.customTransform
(String stageName, SupplierEx<Processor> procSupplier) <R> BatchStage<R>
BatchStage.customTransform
(String stageName, ProcessorMetaSupplier procSupplier) default <R> BatchStage<R>
BatchStage.customTransform
(String stageName, ProcessorSupplier procSupplier) default <R> BatchStage<R>
BatchStageWithKey.customTransform
(String stageName, SupplierEx<Processor> procSupplier) <R> BatchStage<R>
BatchStageWithKey.customTransform
(String stageName, ProcessorMetaSupplier procSupplier) default <R> BatchStage<R>
BatchStageWithKey.customTransform
(String stageName, ProcessorSupplier procSupplier) default BatchStage<T>
BatchStage.distinct()
Attaches a stage that emits just the items that are distinct according to their definition of equality (equals
andhashCode
).BatchStageWithKey.distinct()
Attaches a stage that emits just the items that are distinct according to the grouping key (no two items which map to the same key will be on the output).BatchStage.filter
(PredicateEx<T> filterFn) <S> BatchStage<T>
BatchStage.filterStateful
(SupplierEx<? extends S> createFn, BiPredicateEx<? super S, ? super T> filterFn) <S> BatchStage<T>
BatchStageWithKey.filterStateful
(SupplierEx<? extends S> createFn, BiPredicateEx<? super S, ? super T> filterFn) <S> BatchStage<T>
BatchStage.filterUsingService
(ServiceFactory<?, S> serviceFactory, BiPredicateEx<? super S, ? super T> filterFn) <S> BatchStage<T>
BatchStageWithKey.filterUsingService
(ServiceFactory<?, S> serviceFactory, TriPredicate<? super S, ? super K, ? super T> filterFn) <R> BatchStage<R>
BatchStage.flatMap
(FunctionEx<? super T, ? extends Traverser<R>> flatMapFn) <S,
R> BatchStage<R> BatchStage.flatMapStateful
(SupplierEx<? extends S> createFn, BiFunctionEx<? super S, ? super T, ? extends Traverser<R>> flatMapFn) <S,
R> BatchStage<R> BatchStageWithKey.flatMapStateful
(SupplierEx<? extends S> createFn, TriFunction<? super S, ? super K, ? super T, ? extends Traverser<R>> flatMapFn) <S,
R> BatchStage<R> BatchStage.flatMapUsingService
(ServiceFactory<?, S> serviceFactory, BiFunctionEx<? super S, ? super T, ? extends Traverser<R>> flatMapFn) <S,
R> BatchStage<R> BatchStageWithKey.flatMapUsingService
(ServiceFactory<?, S> serviceFactory, TriFunction<? super S, ? super K, ? super T, ? extends Traverser<R>> flatMapFn) <K,
T1_IN, T1, R>
BatchStage<R>BatchStage.hashJoin
(BatchStage<T1_IN> stage1, JoinClause<K, ? super T, ? super T1_IN, ? extends T1> joinClause1, BiFunctionEx<T, T1, R> mapToOutputFn) <K1,
K2, T1_IN, T2_IN, T1, T2, R>
BatchStage<R>BatchStage.hashJoin2
(BatchStage<T1_IN> stage1, JoinClause<K1, ? super T, ? super T1_IN, ? extends T1> joinClause1, BatchStage<T2_IN> stage2, JoinClause<K2, ? super T, ? super T2_IN, ? extends T2> joinClause2, TriFunction<T, T1, T2, R> mapToOutputFn) <K,
T1_IN, T1, R>
BatchStage<R>BatchStage.innerHashJoin
(BatchStage<T1_IN> stage1, JoinClause<K, ? super T, ? super T1_IN, ? extends T1> joinClause1, BiFunctionEx<T, T1, R> mapToOutputFn) <K1,
K2, T1_IN, T2_IN, T1, T2, R>
BatchStage<R>BatchStage.innerHashJoin2
(BatchStage<T1_IN> stage1, JoinClause<K1, ? super T, ? super T1_IN, ? extends T1> joinClause1, BatchStage<T2_IN> stage2, JoinClause<K2, ? super T, ? super T2_IN, ? extends T2> joinClause2, TriFunction<T, T1, T2, R> mapToOutputFn) <R> BatchStage<R>
BatchStage.map
(FunctionEx<? super T, ? extends R> mapFn) <S,
R> BatchStage<R> BatchStage.mapStateful
(SupplierEx<? extends S> createFn, BiFunctionEx<? super S, ? super T, ? extends R> mapFn) <S,
R> BatchStage<R> BatchStageWithKey.mapStateful
(SupplierEx<? extends S> createFn, TriFunction<? super S, ? super K, ? super T, ? extends R> mapFn) default <K,
V, R> BatchStage<R> BatchStage.mapUsingIMap
(IMap<K, V> iMap, FunctionEx<? super T, ? extends K> lookupKeyFn, BiFunctionEx<? super T, ? super V, ? extends R> mapFn) default <K,
V, R> BatchStage<R> BatchStage.mapUsingIMap
(String mapName, FunctionEx<? super T, ? extends K> lookupKeyFn, BiFunctionEx<? super T, ? super V, ? extends R> mapFn) default <V,
R> BatchStage<R> BatchStageWithKey.mapUsingIMap
(IMap<K, V> iMap, BiFunctionEx<? super T, ? super V, ? extends R> mapFn) default <V,
R> BatchStage<R> BatchStageWithKey.mapUsingIMap
(String mapName, BiFunctionEx<? super T, ? super V, ? extends R> mapFn) default <K,
V, R> BatchStage<R> BatchStage.mapUsingReplicatedMap
(ReplicatedMap<K, V> replicatedMap, FunctionEx<? super T, ? extends K> lookupKeyFn, BiFunctionEx<? super T, ? super V, ? extends R> mapFn) default <K,
V, R> BatchStage<R> BatchStage.mapUsingReplicatedMap
(String mapName, FunctionEx<? super T, ? extends K> lookupKeyFn, BiFunctionEx<? super T, ? super V, ? extends R> mapFn) <S,
R> BatchStage<R> BatchStage.mapUsingService
(ServiceFactory<?, S> serviceFactory, BiFunctionEx<? super S, ? super T, ? extends R> mapFn) <S,
R> BatchStage<R> BatchStageWithKey.mapUsingService
(ServiceFactory<?, S> serviceFactory, TriFunction<? super S, ? super K, ? super T, ? extends R> mapFn) <S,
R> BatchStage<R> BatchStage.mapUsingServiceAsync
(ServiceFactory<?, S> serviceFactory, int maxConcurrentOps, boolean preserveOrder, BiFunctionEx<? super S, ? super T, ? extends CompletableFuture<R>> mapAsyncFn) default <S,
R> BatchStage<R> BatchStage.mapUsingServiceAsync
(ServiceFactory<?, S> serviceFactory, BiFunctionEx<? super S, ? super T, ? extends CompletableFuture<R>> mapAsyncFn) <S,
R> BatchStage<R> BatchStageWithKey.mapUsingServiceAsync
(ServiceFactory<?, S> serviceFactory, int maxConcurrentOps, boolean preserveOrder, TriFunction<? super S, ? super K, ? super T, CompletableFuture<R>> mapAsyncFn) default <S,
R> BatchStage<R> BatchStageWithKey.mapUsingServiceAsync
(ServiceFactory<?, S> serviceFactory, TriFunction<? super S, ? super K, ? super T, CompletableFuture<R>> mapAsyncFn) <S,
R> BatchStage<R> BatchStage.mapUsingServiceAsyncBatched
(ServiceFactory<?, S> serviceFactory, int maxBatchSize, BiFunctionEx<? super S, ? super List<T>, ? extends CompletableFuture<List<R>>> mapAsyncFn) <S,
R> BatchStage<R> BatchStageWithKey.mapUsingServiceAsyncBatched
(ServiceFactory<?, S> serviceFactory, int maxBatchSize, BiFunctionEx<? super S, ? super List<T>, ? extends CompletableFuture<List<R>>> mapAsyncFn) <S,
R> BatchStage<R> BatchStageWithKey.mapUsingServiceAsyncBatched
(ServiceFactory<?, S> serviceFactory, int maxBatchSize, TriFunction<? super S, ? super List<K>, ? super List<T>, ? extends CompletableFuture<List<R>>> mapAsyncFn) BatchStage.merge
(BatchStage<? extends T> other) Attaches a stage that emits all the items from this stage as well as all the items from the supplied stage.default BatchStage<T>
BatchStage.peek()
default BatchStage<T>
BatchStage.peek
(FunctionEx<? super T, ? extends CharSequence> toStringFn) BatchStage.peek
(PredicateEx<? super T> shouldLogFn, FunctionEx<? super T, ? extends CharSequence> toStringFn) <T> BatchStage<T>
Pipeline.readFrom
(BatchSource<? extends T> source) Returns a pipeline stage that represents a bounded (batch) data source.BatchStage.rebalance()
<K> BatchStage<T>
BatchStage.rebalance
(FunctionEx<? super T, ? extends K> keyFn) default <A,
R> BatchStage<R> BatchStage.rollingAggregate
(AggregateOperation1<? super T, A, ? extends R> aggrOp) default <A,
R> BatchStage<Map.Entry<K, R>> BatchStageWithKey.rollingAggregate
(AggregateOperation1<? super T, A, ? extends R> aggrOp) BatchStage.setLocalParallelism
(int localParallelism) BatchStage.sort()
Attaches a stage that sorts the input items according to their natural order.BatchStage.sort
(ComparatorEx<? super T> comparator) Attaches a stage that sorts the input items according to the supplied comparator.Modifier and TypeMethodDescription<T,
R> Tag<R> AggregateBuilder.add
(BatchStage<T> stage, AggregateOperation1<? super T, ?, ? extends R> aggrOp) Adds another stage that will contribute its data to the aggregate operation to be performed.<T> Tag<T>
AggregateBuilder1.add
(BatchStage<T> stage) Adds another stage that will contribute its data to the aggregate operation to be performed.<K,
T1_IN, T1>
Tag<T1>GeneralHashJoinBuilder.add
(BatchStage<T1_IN> stage, JoinClause<K, T0, T1_IN, T1> joinClause) Adds another contributing pipeline stage to the hash-join operation.<K,
T1_IN, T1>
Tag<T1>GeneralHashJoinBuilder.addInner
(BatchStage<T1_IN> stage, JoinClause<K, T0, T1_IN, T1> joinClause) Adds another contributing pipeline stage to the hash-join operation.default <T1,
R0, R1> BatchStage<Tuple2<R0, R1>> BatchStage.aggregate2
(AggregateOperation1<? super T, ?, ? extends R0> aggrOp0, BatchStage<T1> stage1, AggregateOperation1<? super T1, ?, ? extends R1> aggrOp1) Attaches a stage that co-aggregates the data from this and the supplied stage by performing a separate aggregate operation on each and emits a singleTuple2
with their results.<T1,
R> BatchStage<R> BatchStage.aggregate2
(BatchStage<T1> stage1, AggregateOperation2<? super T, ? super T1, ?, ? extends R> aggrOp) Attaches a stage that performs the given aggregate operation over all the items it receives from both this stage andstage1
you supply.default <T1,
T2, R0, R1, R2>
BatchStage<Tuple3<R0,R1, R2>> BatchStage.aggregate3
(AggregateOperation1<? super T, ?, ? extends R0> aggrOp0, BatchStage<T1> stage1, AggregateOperation1<? super T1, ?, ? extends R1> aggrOp1, BatchStage<T2> stage2, AggregateOperation1<? super T2, ?, ? extends R2> aggrOp2) Attaches a stage that co-aggregates the data from this and the two supplied stages by performing a separate aggregate operation on each and emits a singleTuple3
with their results.<T1,
T2, R> BatchStage<R> BatchStage.aggregate3
(BatchStage<T1> stage1, BatchStage<T2> stage2, AggregateOperation3<? super T, ? super T1, ? super T2, ?, ? extends R> aggrOp) Attaches a stage that performs the given aggregate operation over all the items it receives from this stage as well asstage1
andstage2
you supply.<K,
T1_IN, T1, R>
BatchStage<R>BatchStage.hashJoin
(BatchStage<T1_IN> stage1, JoinClause<K, ? super T, ? super T1_IN, ? extends T1> joinClause1, BiFunctionEx<T, T1, R> mapToOutputFn) <K,
T1_IN, T1, R>
GeneralStage<R>GeneralStage.hashJoin
(BatchStage<T1_IN> stage1, JoinClause<K, ? super T, ? super T1_IN, ? extends T1> joinClause1, BiFunctionEx<T, T1, R> mapToOutputFn) Attaches to both this and the supplied stage a hash-joining stage and returns it.<K,
T1_IN, T1, R>
StreamStage<R>StreamStage.hashJoin
(BatchStage<T1_IN> stage1, JoinClause<K, ? super T, ? super T1_IN, ? extends T1> joinClause1, BiFunctionEx<T, T1, R> mapToOutputFn) <K1,
K2, T1_IN, T2_IN, T1, T2, R>
BatchStage<R>BatchStage.hashJoin2
(BatchStage<T1_IN> stage1, JoinClause<K1, ? super T, ? super T1_IN, ? extends T1> joinClause1, BatchStage<T2_IN> stage2, JoinClause<K2, ? super T, ? super T2_IN, ? extends T2> joinClause2, TriFunction<T, T1, T2, R> mapToOutputFn) <K1,
K2, T1_IN, T2_IN, T1, T2, R>
GeneralStage<R>GeneralStage.hashJoin2
(BatchStage<T1_IN> stage1, JoinClause<K1, ? super T, ? super T1_IN, ? extends T1> joinClause1, BatchStage<T2_IN> stage2, JoinClause<K2, ? super T, ? super T2_IN, ? extends T2> joinClause2, TriFunction<T, T1, T2, R> mapToOutputFn) Attaches to this and the two supplied stages a hash-joining stage and returns it.<K1,
K2, T1_IN, T2_IN, T1, T2, R>
StreamStage<R>StreamStage.hashJoin2
(BatchStage<T1_IN> stage1, JoinClause<K1, ? super T, ? super T1_IN, ? extends T1> joinClause1, BatchStage<T2_IN> stage2, JoinClause<K2, ? super T, ? super T2_IN, ? extends T2> joinClause2, TriFunction<T, T1, T2, R> mapToOutputFn) <K,
T1_IN, T1, R>
BatchStage<R>BatchStage.innerHashJoin
(BatchStage<T1_IN> stage1, JoinClause<K, ? super T, ? super T1_IN, ? extends T1> joinClause1, BiFunctionEx<T, T1, R> mapToOutputFn) <K,
T1_IN, T1, R>
GeneralStage<R>GeneralStage.innerHashJoin
(BatchStage<T1_IN> stage1, JoinClause<K, ? super T, ? super T1_IN, ? extends T1> joinClause1, BiFunctionEx<T, T1, R> mapToOutputFn) Attaches to both this and the supplied stage an inner hash-joining stage and returns it.<K,
T1_IN, T1, R>
StreamStage<R>StreamStage.innerHashJoin
(BatchStage<T1_IN> stage1, JoinClause<K, ? super T, ? super T1_IN, ? extends T1> joinClause1, BiFunctionEx<T, T1, R> mapToOutputFn) <K1,
K2, T1_IN, T2_IN, T1, T2, R>
BatchStage<R>BatchStage.innerHashJoin2
(BatchStage<T1_IN> stage1, JoinClause<K1, ? super T, ? super T1_IN, ? extends T1> joinClause1, BatchStage<T2_IN> stage2, JoinClause<K2, ? super T, ? super T2_IN, ? extends T2> joinClause2, TriFunction<T, T1, T2, R> mapToOutputFn) <K1,
K2, T1_IN, T2_IN, T1, T2, R>
GeneralStage<R>GeneralStage.innerHashJoin2
(BatchStage<T1_IN> stage1, JoinClause<K1, ? super T, ? super T1_IN, ? extends T1> joinClause1, BatchStage<T2_IN> stage2, JoinClause<K2, ? super T, ? super T2_IN, ? extends T2> joinClause2, TriFunction<T, T1, T2, R> mapToOutputFn) Attaches to this and the two supplied stages an inner hash-joining stage and returns it.<K1,
K2, T1_IN, T2_IN, T1, T2, R>
StreamStage<R>StreamStage.innerHashJoin2
(BatchStage<T1_IN> stage1, JoinClause<K1, ? super T, ? super T1_IN, ? extends T1> joinClause1, BatchStage<T2_IN> stage2, JoinClause<K2, ? super T, ? super T2_IN, ? extends T2> joinClause2, TriFunction<T, T1, T2, R> mapToOutputFn) BatchStage.merge
(BatchStage<? extends T> other) Attaches a stage that emits all the items from this stage as well as all the items from the supplied stage.Modifier and TypeMethodDescriptiondefault <R> BatchStage<R>
BatchStage.apply
(FunctionEx<? super BatchStage<T>, ? extends BatchStage<R>> transformFn) Transformsthis
stage using the providedtransformFn
and returns the transformed stage.default <R> BatchStage<R>
BatchStage.apply
(FunctionEx<? super BatchStage<T>, ? extends BatchStage<R>> transformFn) Transformsthis
stage using the providedtransformFn
and returns the transformed stage. -
Uses of BatchStage in com.hazelcast.jet.pipeline.test
Modifier and TypeMethodDescriptionstatic <T> FunctionEx<BatchStage<T>,
BatchStage<T>> Assertions.assertAnyOrder
(String message, Collection<? extends T> expected) Asserts that the previous stage emitted the expected items in any order, but nothing else.static <T> FunctionEx<BatchStage<T>,
BatchStage<T>> Assertions.assertAnyOrder
(String message, Collection<? extends T> expected) Asserts that the previous stage emitted the expected items in any order, but nothing else.static <T> FunctionEx<BatchStage<T>,
BatchStage<T>> Assertions.assertAnyOrder
(Collection<? extends T> expected) Asserts that the previous stage emitted the expected items in any order, but nothing else.static <T> FunctionEx<BatchStage<T>,
BatchStage<T>> Assertions.assertAnyOrder
(Collection<? extends T> expected) Asserts that the previous stage emitted the expected items in any order, but nothing else.static <T> FunctionEx<BatchStage<T>,
BatchStage<T>> Assertions.assertCollected
(ConsumerEx<? super List<T>> assertFn) Collects all the received items in a list and once the upstream stage is completed, it executes the assertion supplied byassertFn
.static <T> FunctionEx<BatchStage<T>,
BatchStage<T>> Assertions.assertCollected
(ConsumerEx<? super List<T>> assertFn) Collects all the received items in a list and once the upstream stage is completed, it executes the assertion supplied byassertFn
.static <T> FunctionEx<BatchStage<T>,
BatchStage<T>> Assertions.assertContains
(String message, Collection<? extends T> expected) Asserts that the previous stage emitted all of the given items in any order.static <T> FunctionEx<BatchStage<T>,
BatchStage<T>> Assertions.assertContains
(String message, Collection<? extends T> expected) Asserts that the previous stage emitted all of the given items in any order.static <T> FunctionEx<BatchStage<T>,
BatchStage<T>> Assertions.assertContains
(Collection<? extends T> expected) Asserts that the previous stage emitted all of the given items in any order.static <T> FunctionEx<BatchStage<T>,
BatchStage<T>> Assertions.assertContains
(Collection<? extends T> expected) Asserts that the previous stage emitted all of the given items in any order.static <T> FunctionEx<BatchStage<T>,
BatchStage<T>> Assertions.assertOrdered
(String message, Collection<? extends T> expected) Asserts that the previous stage emitted the exact sequence of expected items and nothing else.static <T> FunctionEx<BatchStage<T>,
BatchStage<T>> Assertions.assertOrdered
(String message, Collection<? extends T> expected) Asserts that the previous stage emitted the exact sequence of expected items and nothing else.static <T> FunctionEx<BatchStage<T>,
BatchStage<T>> Assertions.assertOrdered
(Collection<? extends T> expected) Asserts that the previous stage emitted the exact sequence of expected items and nothing else.static <T> FunctionEx<BatchStage<T>,
BatchStage<T>> Assertions.assertOrdered
(Collection<? extends T> expected) Asserts that the previous stage emitted the exact sequence of expected items and nothing else. -
Uses of BatchStage in com.hazelcast.jet.python
Modifier and TypeMethodDescriptionstatic <K> FunctionEx<BatchStage<String>,
BatchStage<String>> PythonTransforms.mapUsingPythonBatch
(FunctionEx<? super String, ? extends K> keyFn, PythonServiceConfig cfg) A stage-transforming method that adds a partitioned "map using Python" pipeline stage.static <K> FunctionEx<BatchStage<String>,
BatchStage<String>> PythonTransforms.mapUsingPythonBatch
(FunctionEx<? super String, ? extends K> keyFn, PythonServiceConfig cfg) A stage-transforming method that adds a partitioned "map using Python" pipeline stage.static FunctionEx<BatchStage<String>,
BatchStage<String>> PythonTransforms.mapUsingPythonBatch
(PythonServiceConfig cfg) A stage-transforming method that adds a "map using Python" pipeline stage.static FunctionEx<BatchStage<String>,
BatchStage<String>> PythonTransforms.mapUsingPythonBatch
(PythonServiceConfig cfg) A stage-transforming method that adds a "map using Python" pipeline stage.