Details

      Description

      On https://ci.apache.org/projects/flink/flink-docs-master/dev/table/sql.html , the example is :

      StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();
      StreamTableEnvironment tableEnv = TableEnvironment.getTableEnvironment(env);
      
      // ingest a DataStream from an external source
      DataStream<Tuple3<Long, String, Integer>> ds = env.addSource(...);
      
      // SQL query with an inlined (unregistered) table
      Table table = tableEnv.toTable(ds, "user, product, amount");
      Table result = tableEnv.sqlQuery(
        "SELECT SUM(amount) FROM " + table + " WHERE product LIKE '%Rubber%'");
      ...
      

      But there's no API of toTable() in StreamTableEnvironment

      cc Fabian Hueske

        Attachments

          Issue Links

            Activity

              People

              • Assignee:
                phoenixjiangnan Bowen Li
                Reporter:
                phoenixjiangnan Bowen Li
              • Votes:
                0 Vote for this issue
                Watchers:
                4 Start watching this issue

                Dates

                • Created:
                  Updated:
                  Resolved: