Uploaded image for project: 'Flink'
  1. Flink
  2. FLINK-25217 FLIP-190: Support Version Upgrades for Table API & SQL Programs
  3. FLINK-25392

Add new STATEMENT SET syntax

    XMLWordPrintableJSON

Details

    • Hide
      It is recommended to update statement sets to the new SQL syntax: EXECUTE STATEMENT SET BEGIN ... END;
      EXPLAIN STATEMENT SET BEGIN ... END;
      Show
      It is recommended to update statement sets to the new SQL syntax: EXECUTE STATEMENT SET BEGIN ... END; EXPLAIN STATEMENT SET BEGIN ... END;

    Description

      Support:

      EXECUTE STATEMENT SET
BEGIN
  INSERT INTO pageview_pv_sink
  SELECT page_id, count(1) FROM clicks GROUP BY page_id;

  INSERT INTO pageview_uv_sink
  SELECT page_id, count(distinct user_id) FROM clicks GROUP BY page_id;
END;

      EXPLAIN STATEMENT SET
BEGIN
  INSERT INTO pageview_pv_sink
  SELECT page_id, count(1) FROM clicks GROUP BY page_id;

  INSERT INTO pageview_uv_sink
  SELECT page_id, count(distinct user_id) FROM clicks GROUP BY page_id;
END;

      This time we should add this to the SQL parser. We need to figure out a solution for the interactive SQL Client.

      Attachments

        Issue Links

          is related to

          Sub-task - The sub-task of the issue FLINK-25600 Support new statement set syntax in sql client and update docs

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

          Web Link GitHub Pull Request #18215

          Activity

            People

              wenlong.lwl Wenlong Lyu
              twalthr Timo Walther
              Votes:
              0 Vote for this issue
              Watchers:
              3 Start watching this issue

              Dates

                Created:
                Updated:
                Resolved: