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 Summary

Modifier and Type	Method and Description
<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

Methods inherited from class java.lang.Object

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

Method Detail

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