Package | Description |
---|---|
org.apache.flink.streaming.api.datastream |
Modifier and Type | Method and Description |
---|---|
KeyedStream.IntervalJoined<T1,T2,KEY> |
KeyedStream.IntervalJoin.between(Time lowerBound,
Time upperBound)
Specifies the time boundaries over which the join operation works, so that
|
KeyedStream.IntervalJoined<IN1,IN2,KEY> |
KeyedStream.IntervalJoined.lowerBoundExclusive()
Set the lower bound to be exclusive.
|
KeyedStream.IntervalJoined<IN1,IN2,KEY> |
KeyedStream.IntervalJoined.upperBoundExclusive()
Set the upper bound to be exclusive.
|
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.