Details

    • Type: Sub-task
    • Status: Closed
    • Priority: Major
    • Resolution: Implemented
    • Affects Version/s: None
    • Fix Version/s: 1.3.0
    • Component/s: Table API & SQL
    • Labels:
      None

      Description

      Syntax:

      table
         .overWindows(
          (Rows|Range [ partitionBy value_expression , ... [ n ]] [ orderBy order_by_expression] 
            (preceding  UNBOUNDED|value_specification.(rows|milli|second|minute|hour|day|month|year)|CURRENTROW)
           [following UNBOUNDED|value_specification.(rows|milli|second|minute|hour|day|month|year)|CURRENTROW]
          as alias,...[n])
         )
        .select( [col1,...[n]], (agg(col1) OVER overWindowAlias, … [n])
      

      Implement restrictions:

      • All OVER clauses in the same SELECT clause must be exactly the same.
      • The PARTITION BY clause is optional (no partitioning results in single threaded execution).
      • The ORDER BY Before the FLINK-5884 implementation orderBy may only have ‘rowtime/’proctime(for stream)/‘specific-time-field(for batch).
      • FOLLOWING is not supported.

      User interface design document See

        Attachments

          Issue Links

            Activity

              People

              • Assignee:
                sunjincheng121 sunjincheng
                Reporter:
                sunjincheng121 sunjincheng
              • Votes:
                0 Vote for this issue
                Watchers:
                3 Start watching this issue

                Dates

                • Created:
                  Updated:
                  Resolved: