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

Add FlatAggregate support to stream Table API(blink planner)

Attach filesAttach ScreenshotVotersWatch issueWatchersLinkCloneUpdate Comment AuthorReplace String in CommentUpdate Comment VisibilityDelete Comments
    XMLWordPrintableJSON

    Details

      Description

      Add FlatAggregate support to stream Table API(blink planner), i.e, align with flink planner.
      The API looks like:

       TableAggregateFunction tableAggFunc = new MyTableAggregateFunction();
       tableEnv.registerFunction("tableAggFunc", tableAggFunc);
      tab.groupBy("key")
         .flatAggregate("tableAggFunc(a, b) as (x, y, z)")
         .select("key, x, y, z")
      
      

      The detail can be found in Flip-29

        Attachments

          Activity

            People

            • Assignee:
              sunjincheng121 sunjincheng
              Reporter:
              sunjincheng121 sunjincheng

              Dates

              • Created:
                Updated:
                Resolved:

                Time Tracking

                Estimated:
                Original Estimate - Not Specified
                Not Specified
                Remaining:
                Remaining Estimate - 0h
                0h
                Logged:
                Time Spent - 10m
                10m

                  Issue deployment