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
public class StreamHashJoinBuilder<T0> extends GeneralHashJoinBuilder<T0>
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 Details

    • build

      public <R> StreamStage<R> build(BiFunctionEx<T0,ItemsByTag,R> mapToOutputFn)
      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