T1
- The type parameter of the elements in the first streamsT2
- The type parameter of the elements in the second stream@PublicEvolving public static class KeyedStream.IntervalJoin<T1,T2,KEY> extends Object
Modifier and Type | Method and Description |
---|---|
KeyedStream.IntervalJoined<T1,T2,KEY> |
between(java.time.Duration lowerBound,
java.time.Duration upperBound)
Specifies the time boundaries over which the join operation works, so that
|
KeyedStream.IntervalJoined<T1,T2,KEY> |
between(Time lowerBound,
Time upperBound)
Deprecated.
|
KeyedStream.IntervalJoin<T1,T2,KEY> |
inEventTime()
Sets the time characteristic to event time.
|
KeyedStream.IntervalJoin<T1,T2,KEY> |
inProcessingTime()
Sets the time characteristic to processing time.
|
public KeyedStream.IntervalJoin<T1,T2,KEY> inEventTime()
public KeyedStream.IntervalJoin<T1,T2,KEY> inProcessingTime()
@Deprecated @PublicEvolving public KeyedStream.IntervalJoined<T1,T2,KEY> between(Time lowerBound, Time upperBound)
between(Duration, Duration)
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()
lowerBound
- The lower bound. Needs to be smaller than or equal to the upperBoundupperBound
- The upper bound. Needs to be bigger than or equal to the lowerBound@PublicEvolving public KeyedStream.IntervalJoined<T1,T2,KEY> between(java.time.Duration lowerBound, java.time.Duration upperBound)
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()
lowerBound
- The lower bound. Needs to be smaller than or equal to the upperBoundupperBound
- The upper bound. Needs to be bigger than or equal to the lowerBoundCopyright © 2014–2024 The Apache Software Foundation. All rights reserved.