Uses of Class
com.hazelcast.jet.pipeline.JoinClause
Package | Description |
---|---|
com.hazelcast.jet.pipeline |
The Pipeline API is Jet's high-level API to build and execute
distributed computation jobs.
|
-
Uses of JoinClause in com.hazelcast.jet.pipeline
Methods in com.hazelcast.jet.pipeline that return JoinClause Modifier and Type Method Description static <K, T0, T1_OUT>
JoinClause<K,T0,Map.Entry<K,T1_OUT>,T1_OUT>JoinClause. joinMapEntries(FunctionEx<? super T0,? extends K> leftKeyFn)
A shorthand factory for the common case of hash-joining with a stream of map entries.static <K, T0, T1> JoinClause<K,T0,T1,T1>
JoinClause. onKeys(FunctionEx<? super T0,? extends K> leftKeyFn, FunctionEx<? super T1,? extends K> rightKeyFn)
Constructs and returns a join clause with the supplied left-hand and right-hand key extractor functions, and with an identity right-hand projection function.<T1_NEW_OUT>
JoinClause<K,T0,T1,T1_NEW_OUT>JoinClause. projecting(FunctionEx<? super T1,? extends T1_NEW_OUT> rightProjectFn)
Returns a copy of this join clause, but with the right-hand projection function replaced with the supplied one.Methods in com.hazelcast.jet.pipeline with parameters of type JoinClause Modifier and Type Method Description <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.<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)