Package | Description |
---|---|
com.hazelcast.jet |
The Pipeline API is Jet's high-level API to build and execute
distributed computation jobs.
|
Modifier and Type | Method and Description |
---|---|
static <K,E0,E1_IN extends Map.Entry<K,E1>,E1> |
JoinClause.joinMapEntries(DistributedFunction<E0,K> leftKeyFn)
A shorthand factory for the common case of hash-joining with a stream of
map entries.
|
static <K,E0,E1> JoinClause<K,E0,E1,E1> |
JoinClause.onKeys(DistributedFunction<E0,K> leftKeyFn,
DistributedFunction<E1,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.
|
<E1_NEW_OUT> |
JoinClause.projecting(DistributedFunction<E1,E1_NEW_OUT> rightProjectFn)
Returns a copy of this join clause, but with the right-hand projection
function replaced with the supplied one.
|
Modifier and Type | Method and Description |
---|---|
<K,E1_IN,E1> |
HashJoinBuilder.add(ComputeStage<E1_IN> stage,
JoinClause<K,E0,E1_IN,E1> joinClause)
Adds another contributing pipeline stage to the hash-join operation.
|
<K1,E1_IN,E1,K2,E2_IN,E2> |
ComputeStage.hashJoin(ComputeStage<E1_IN> stage1,
JoinClause<K1,E,E1_IN,E1> joinClause1,
ComputeStage<E2_IN> stage2,
JoinClause<K2,E,E2_IN,E2> joinClause2)
Attaches to this and the two supplied stages a hash-joining stage and
returns it.
|
<K1,E1_IN,E1,K2,E2_IN,E2> |
ComputeStage.hashJoin(ComputeStage<E1_IN> stage1,
JoinClause<K1,E,E1_IN,E1> joinClause1,
ComputeStage<E2_IN> stage2,
JoinClause<K2,E,E2_IN,E2> joinClause2)
Attaches to this and the two supplied stages a hash-joining stage and
returns it.
|
<K,E1_IN,E1> |
ComputeStage.hashJoin(ComputeStage<E1_IN> stage1,
JoinClause<K,E,E1_IN,E1> joinClause)
Attaches to both this and the supplied stage a hash-joining stage and
returns it.
|
Copyright © 2017 Hazelcast, Inc.. All Rights Reserved.