org.apache.flink.streaming.api.datastream

Class KeyedStream.IntervalJoin<T1,T2,KEY>

java.lang.Object

org.apache.flink.streaming.api.datastream.KeyedStream.IntervalJoin<T1,T2,KEY>

Type Parameters:

T1 - The type parameter of the elements in the first streams

T2 - The The type parameter of the elements in the second stream

Enclosing class:

KeyedStream<T,KEY>

@PublicEvolving
public static class KeyedStream.IntervalJoin<T1,T2,KEY>
extends Object

Perform a join over a time interval.

Method Summary

Modifier and Type	Method and Description
KeyedStream.IntervalJoined<T1,T2,KEY>	between(Time lowerBound, Time upperBound) Specifies the time boundaries over which the join operation works, so that

Methods inherited from class java.lang.Object

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

Method Detail

between

@PublicEvolving
public KeyedStream.IntervalJoined<T1,T2,KEY> between(Time lowerBound,
                                                                     Time upperBound)

Specifies the time boundaries over which the join operation works, so that

leftElement.timestamp + lowerBound <= rightElement.timestamp <= leftElement.timestamp + upperBound

By default both the lower and the upper bound are inclusive. This can be configured with KeyedStream.IntervalJoined.lowerBoundExclusive() and KeyedStream.IntervalJoined.upperBoundExclusive()

Parameters:

lowerBound - The lower bound. Needs to be smaller than or equal to the upperBound

upperBound - The upper bound. Needs to be bigger than or equal to the lowerBound