com.hazelcast.jet

Class HashJoinBuilder<E0>

java.lang.Object

com.hazelcast.jet.HashJoinBuilder<E0>

Type Parameters:

E0 - the type of the stream-0 item

public class HashJoinBuilder<E0>
extends Object

Offers a step-by-step fluent API to build a hash-join pipeline stage. To obtain it, call ComputeStage.hashJoinBuilder() on the primary stage, whose data will be enriched from all other stages.

This object is mainly intended to build a hash-join of the primary stage with three or more contributing stages. For one or two stages the direct stage.hashJoin(...) calls should be preferred because they offer more static type safety.

Method Summary

Modifier and Type	Method and Description
<K,E1_IN,E1> Tag<E1>	add(ComputeStage<E1_IN> stage, JoinClause<K,E0,E1_IN,E1> joinClause) Adds another contributing pipeline stage to the hash-join operation.
ComputeStage<Tuple2<E0,ItemsByTag>>	build() Builds a new pipeline stage that performs the hash-join operation.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

add

public <K,E1_IN,E1> Tag<E1> add(ComputeStage<E1_IN> stage,
                                JoinClause<K,E0,E1_IN,E1> joinClause)

Adds another contributing pipeline stage to the hash-join operation.

Type Parameters:

K - the type of the join key

E1_IN - the type of the contributing stage's data

E1 - the type of result after applying the projecting transformation to the contributing stage's data

Parameters:

stage - the contributing stage

joinClause - specifies how to join the contributing stage

Returns:

the tag that refers to the contributing stage

build

public ComputeStage<Tuple2<E0,ItemsByTag>> build()

Builds a new pipeline stage that performs the hash-join operation. The stage is attached to all the contributing stages.

Returns:

the hash-join pipeline stage