Uses of Interface
com.hazelcast.jet.pipeline.BatchStage
Package | Description |
---|---|
com.hazelcast.jet.pipeline |
The Pipeline API is Jet's high-level API to build and execute
distributed computation jobs.
|
com.hazelcast.jet.pipeline.test |
This package contains various mock sources to help with pipeline testing
and development.
|
com.hazelcast.jet.python |
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
Methods in com.hazelcast.jet.pipeline that return BatchStage Modifier and Type Method Description <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.BatchStage<ItemsByTag>
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.BatchStage<Map.Entry<K,ItemsByTag>>
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
).BatchStage<T>
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<T>
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<T>
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<T>
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<T>
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<T>
BatchStage. setLocalParallelism(int localParallelism)
BatchStage<T>
BatchStage. setName(String name)
BatchStage<T>
BatchStage. sort()
Attaches a stage that sorts the input items according to their natural order.BatchStage<T>
BatchStage. sort(ComparatorEx<? super T> comparator)
Attaches a stage that sorts the input items according to the supplied comparator.Methods in com.hazelcast.jet.pipeline with parameters of type BatchStage Modifier and Type Method Description <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 a 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<T>
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.Method parameters in com.hazelcast.jet.pipeline with type arguments of type BatchStage Modifier and Type Method Description default <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
Methods in com.hazelcast.jet.pipeline.test that return types with arguments of type BatchStage Modifier and Type Method Description 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(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
Methods in com.hazelcast.jet.python that return types with arguments of type BatchStage Modifier and Type Method Description 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 <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.