E0
- the type of the stream-0 itempublic class HashJoinBuilder<E0> extends Object
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.
Modifier and Type | Method and Description |
---|---|
<K,E1_IN,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.
|
public <K,E1_IN,E1> Tag<E1> add(ComputeStage<E1_IN> stage, JoinClause<K,E0,E1_IN,E1> joinClause)
K
- the type of the join keyE1_IN
- the type of the contributing stage's dataE1
- the type of result after applying the projecting transformation
to the contributing stage's datastage
- the contributing stagejoinClause
- specifies how to join the contributing stagepublic ComputeStage<Tuple2<E0,ItemsByTag>> build()
Copyright © 2017 Hazelcast, Inc.. All Rights Reserved.