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	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 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)