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`
---