Uploaded image for project: 'Flink'
  1. Flink
  2. FLINK-13470 Enhancements to Flink Table API for blink planner
  3. FLINK-11052

Add Bounded(Group Window) FlatAggregate operator to batch Table API

    XMLWordPrintableJSON

Details

    • Sub-task
    • Status: Open
    • Major
    • Resolution: Unresolved
    • None
    • None
    • Table SQL / API

    Description

      Add FlatAggregate operator to batch group window Table API as described in FLIP-29.

      The usage:

      tab.window(Tumble/Session/Slide... as 'w)
         .groupBy('w, 'k1, 'k2)
         .flatAggregate(tableAggregate('a))
         .select('w.rowtime, 'k1, 'k2, 'col1, 'col2)
      
      

      Attachments

        Activity

          People

            Unassigned Unassigned
            sunjincheng121 sunjincheng
            Votes:
            0 Vote for this issue
            Watchers:
            5 Start watching this issue

            Dates

              Created:
              Updated: