Uploaded image for project: 'Flink'
  1. Flink
  2. FLINK-3475

DISTINCT aggregate function support for SQL queries

    XMLWordPrintableJSON

Details

    • New Feature
    • Status: Closed
    • Major
    • Resolution: Implemented
    • None
    • 1.3.0
    • Table SQL / API
    • None

    Description

      DISTINCT aggregate function may be able to reuse the aggregate function instead of separate implementation, and let Flink runtime take care of duplicate records.

      Attachments

        Issue Links

          is required by

          Sub-task - The sub-task of the issue FLINK-5315 Support distinct aggregations in table api

          • Major - Major loss of function.
          • Closed
          relates to

          Sub-task - The sub-task of the issue FLINK-5545 Remove FlinkAggregateExpandDistinctAggregatesRule when upgrading to Calcite 1.12

          • Minor - Minor loss of function, or other problem where easy workaround is present.
          • Closed
          links to

          Web Link GitHub Pull Request #3111

          Activity

            People

              docete Zhenghua Gao
              chengxiang li Chengxiang Li
              Votes:
              0 Vote for this issue
              Watchers:
              7 Start watching this issue

              Dates

                Created:
                Updated:
                Resolved: