Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/4625#discussion_r137020297
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/join/WindowJoinUtil.scala
---
@@ -39,14 +39,17 @@ import scala.collection.JavaConverters._
*/
object WindowJoinUtil {
- case class WindowBounds(isEventTime: Boolean, leftLowerBound: Long,
leftUpperBound: Long)
+ case class WindowBounds(isEventTime: Boolean, leftLowerBound: Long,
leftUpperBound: Long,
--- End diff --
change formatting to
```
case class WindowBounds(
isEventTime: Boolean,
leftLowerBound: Long,
...,
rightTimeIdx: Int)
```
similar to `TimePredicate`
---