org.apache.flink.streaming.api.datastream

Class KeyedStream.IntervalJoined<IN1,IN2,KEY>

java.lang.Object

org.apache.flink.streaming.api.datastream.KeyedStream.IntervalJoined<IN1,IN2,KEY>

Type Parameters:

IN1 - Input type of elements from the first stream

IN2 - Input type of elements from the second stream

KEY - The type of the key

Enclosing class:

KeyedStream<T,KEY>

@PublicEvolving
public static class KeyedStream.IntervalJoined<IN1,IN2,KEY>
extends Object

IntervalJoined is a container for two streams that have keys for both sides as well as the time boundaries over which elements should be joined.

Constructor Summary

Constructors

Constructor and Description
IntervalJoined(KeyedStream<IN1,KEY> left, KeyedStream<IN2,KEY> right, long lowerBound, long upperBound, boolean lowerBoundInclusive, boolean upperBoundInclusive)

Method Summary

Modifier and Type	Method and Description
KeyedStream.IntervalJoined<IN1,IN2,KEY>	lowerBoundExclusive() Set the lower bound to be exclusive.
<OUT> SingleOutputStreamOperator<OUT>	process(ProcessJoinFunction<IN1,IN2,OUT> processJoinFunction) Completes the join operation with the given user function that is executed for each joined pair of elements.
<OUT> SingleOutputStreamOperator<OUT>	process(ProcessJoinFunction<IN1,IN2,OUT> processJoinFunction, TypeInformation<OUT> outputType) Completes the join operation with the given user function that is executed for each joined pair of elements.
KeyedStream.IntervalJoined<IN1,IN2,KEY>	sideOutputLeftLateData(OutputTag<IN1> outputTag) Send late arriving left-side data to the side output identified by the given OutputTag.
KeyedStream.IntervalJoined<IN1,IN2,KEY>	sideOutputRightLateData(OutputTag<IN2> outputTag) Send late arriving right-side data to the side output identified by the given OutputTag.
KeyedStream.IntervalJoined<IN1,IN2,KEY>	upperBoundExclusive() Set the upper bound to be exclusive.

Methods inherited from class java.lang.Object

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

Constructor Detail

IntervalJoined

public IntervalJoined(KeyedStream<IN1,KEY> left,
                      KeyedStream<IN2,KEY> right,
                      long lowerBound,
                      long upperBound,
                      boolean lowerBoundInclusive,
                      boolean upperBoundInclusive)

Method Detail

upperBoundExclusive

@PublicEvolving
public KeyedStream.IntervalJoined<IN1,IN2,KEY> upperBoundExclusive()

Set the upper bound to be exclusive.

lowerBoundExclusive

@PublicEvolving
public KeyedStream.IntervalJoined<IN1,IN2,KEY> lowerBoundExclusive()

Set the lower bound to be exclusive.

sideOutputLeftLateData

@PublicEvolving
public KeyedStream.IntervalJoined<IN1,IN2,KEY> sideOutputLeftLateData(OutputTag<IN1> outputTag)

Send late arriving left-side data to the side output identified by the given OutputTag. Data is considered late after the watermark

sideOutputRightLateData

@PublicEvolving
public KeyedStream.IntervalJoined<IN1,IN2,KEY> sideOutputRightLateData(OutputTag<IN2> outputTag)

Send late arriving right-side data to the side output identified by the given OutputTag. Data is considered late after the watermark

process

@PublicEvolving
public <OUT> SingleOutputStreamOperator<OUT> process(ProcessJoinFunction<IN1,IN2,OUT> processJoinFunction)

Completes the join operation with the given user function that is executed for each joined pair of elements.

Type Parameters:

OUT - The output type.

Parameters:

processJoinFunction - The user-defined process join function.

Returns:

The transformed DataStream.

process

@PublicEvolving
public <OUT> SingleOutputStreamOperator<OUT> process(ProcessJoinFunction<IN1,IN2,OUT> processJoinFunction,
                                                                     TypeInformation<OUT> outputType)

Completes the join operation with the given user function that is executed for each joined pair of elements. This methods allows for passing explicit type information for the output type.

Type Parameters:

OUT - The output type.

Parameters:

processJoinFunction - The user-defined process join function.

outputType - The type information for the output type.

Returns:

The transformed DataStream.