Details

    • Type: New Feature
    • Status: Closed
    • Priority: Major
    • Resolution: Fixed
    • Affects Version/s: None
    • Fix Version/s: 2.2.0
    • Component/s: dsl-sql, sdk-ideas
    • Labels:
      None

      Description

      The SQL DSL helps developers to build a Beam pipeline from SQL statement in String directly.
      In Phase I, it starts to support INSERT/SELECT queries with FILTERs, one example SQL as below:

      INSERT INTO `SUB_USEREVENT` (`SITEID`, `PAGEID`, `PAGENAME`, `EVENTTIMESTAMP`)
      (SELECT STREAM `USEREVENT`.`SITEID`, `USEREVENT`.`PAGEID`, `USEREVENT`.`PAGENAME`, `USEREVENT`.`EVENTTIMESTAMP`
      FROM `USEREVENT` AS `USEREVENT`
      WHERE `USEREVENT`.`SITEID` > 10)
      

      A design doc is available at https://docs.google.com/document/d/1Uc5xYTpO9qsLXtT38OfuoqSLimH_0a1Bz5BsCROMzCU/edit?usp=sharing.

        Attachments

          Issue Links

            Activity

              People

              • Assignee:
                mingmxu Xu Mingmin
                Reporter:
                jbonofre Jean-Baptiste Onofré
              • Votes:
                3 Vote for this issue
                Watchers:
                24 Start watching this issue

                Dates

                • Created:
                  Updated:
                  Resolved: