Uses of Class
com.hazelcast.jet.pipeline.JoinClause

Packages that use 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 and 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 and 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> StreamStage<R>	StreamStage.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> 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> 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)
<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)
<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> 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> 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> 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> StreamStage<R>	StreamStage.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> 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> 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)
<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)
<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> 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> 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> 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)