flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From hzyuemeng1 <...@git.apache.org>
Subject [GitHub] flink pull request #2631: The scala example of SQL on Streaming Tables with ...
Date Fri, 14 Oct 2016 04:01:26 GMT
GitHub user hzyuemeng1 opened a pull request:

    https://github.com/apache/flink/pull/2631

    The scala example of SQL on Streaming Tables  with wrong variable name in flink document

    val env = StreamExecutionEnvironment.getExecutionEnvironment
    val tEnv = TableEnvironment.getTableEnvironment(env)
    
    // read a DataStream from an external source
    val ds: DataStream[(Long, String, Integer)] = env.addSource(...)
    // register the DataStream under the name "Orders"
    tableEnv.registerDataStream("Orders", ds, 'user, 'product, 'amount)
    // run a SQL query on the Table and retrieve the result as a new Table
    val result = tableEnv.sql(
      "SELECT product, amount FROM Orders WHERE product LIKE '%Rubber%'")
    
    
    There is no variable named tableEnv had defined ,Only tEnv defined here

You can merge this pull request into a Git repository by running:

    $ git pull https://github.com/hzyuemeng1/flink document_modify_variable_name

Alternatively you can review and apply these changes as the patch at:

    https://github.com/apache/flink/pull/2631.patch

To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:

    This closes #2631
    
----
commit e3f010f68d68f39f62b25eb0190da25ad45c4a14
Author: hzyuemeng1 <hzyuemeng1@corp.netease.com>
Date:   2016-10-14T03:50:36Z

    The scala example of SQL on Streaming Tables  with wrong variable name in flink document

----


---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at infrastructure@apache.org or file a JIRA ticket
with INFRA.
---

Mime
View raw message