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`


---

Reply via email to