Package com.hazelcast.jet.pipeline
Class StreamHashJoinBuilder<T0>
java.lang.Object
com.hazelcast.jet.pipeline.GeneralHashJoinBuilder<T0>
com.hazelcast.jet.pipeline.StreamHashJoinBuilder<T0>
- Type Parameters:
T0
- the type of the items in the primary stage
Offers a step-by-step fluent API to build a hash-join pipeline stage.
To obtain it, call
StreamStage.hashJoinBuilder()
on the primary
stage, the one whose data will be enriched from all other stages.
Collect all the tags returned from add()
and use them to retrieve
the enriching items from ItemsByTag
you get in the result.
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, prefer the
direct stage.hashJoin(...)
calls because they offer more static
type safety.
- Since:
- Jet 3.0
-
Method Summary
Modifier and TypeMethodDescription<R> StreamStage<R>
build
(BiFunctionEx<T0, ItemsByTag, R> mapToOutputFn) Builds a new pipeline stage that performs the hash-join operation.Methods inherited from class com.hazelcast.jet.pipeline.GeneralHashJoinBuilder
add, addInner
-
Method Details
-
build
Builds a new pipeline stage that performs the hash-join operation. Attaches the stage to all the contributing stages.- Parameters:
mapToOutputFn
- the function to map the output item. It must be stateless and cooperative.- Returns:
- the new hash-join pipeline stage
-