You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by tw...@apache.org on 2021/05/19 12:30:21 UTC
[flink] branch master updated (a3b4a08 -> 938680c)

This is an automated email from the ASF dual-hosted git repository.

twalthr pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.


    from a3b4a08  [FLINK-22487][python] Support `print` to print logs in PyFlink
     add bcf8bd7  [FLINK-22697][examples-table] Update StreamSQLExample to current API
     add 54ba156  [FLINK-22697][examples-table] Remove TPCHQuery3Table example
     add 217d703  [FLINK-22697][examples-table] Update WordCountSQLExample to current API
     add 25d1aeb  [FLINK-22697][examples-table] Remove WordCountTable example
     add 1310e78  [FLINK-22697][examples-table] Update flink-examples-table pom.xml
     add 938680c  [hotfix][docs] Update SQL grammar for WITH and sub queries

No new revisions were added by this update.

Summary of changes:
 .../docs/dev/table/sql/queries/overview.md         | 116 ++++++-------
 .../content/docs/dev/table/sql/queries/overview.md | 116 ++++++-------
 flink-examples/flink-examples-table/pom.xml        |  92 +----------
 .../examples/java/basics/StreamSQLExample.java     |  78 ++++-----
 .../table/examples/java/basics/WordCountSQL.java   |  84 ----------
 .../examples/java/basics/WordCountSQLExample.java  |  48 ++++++
 .../table/examples/java/basics/WordCountTable.java |  81 ----------
 .../examples/scala/basics/StreamSQLExample.scala   |  75 ++++-----
 .../examples/scala/basics/TPCHQuery3Table.scala    | 180 ---------------------
 .../table/examples/scala/basics/WordCountSQL.scala |  62 -------
 .../scala/basics/WordCountSQLExample.scala         |  48 ++++++
 .../examples/scala/basics/WordCountTable.scala     |  62 -------
 ...mpleITCase.java => StreamSQLExampleITCase.java} |  12 +-
 ...eITCase.java => WordCountSQLExampleITCase.java} |  11 +-
 ...mpleITCase.java => StreamSQLExampleITCase.java} |  12 +-
 ...eITCase.java => WordCountSQLExampleITCase.java} |  11 +-
 16 files changed, 315 insertions(+), 773 deletions(-)
 delete mode 100644 flink-examples/flink-examples-table/src/main/java/org/apache/flink/table/examples/java/basics/WordCountSQL.java
 create mode 100644 flink-examples/flink-examples-table/src/main/java/org/apache/flink/table/examples/java/basics/WordCountSQLExample.java
 delete mode 100644 flink-examples/flink-examples-table/src/main/java/org/apache/flink/table/examples/java/basics/WordCountTable.java
 delete mode 100644 flink-examples/flink-examples-table/src/main/scala/org/apache/flink/table/examples/scala/basics/TPCHQuery3Table.scala
 delete mode 100644 flink-examples/flink-examples-table/src/main/scala/org/apache/flink/table/examples/scala/basics/WordCountSQL.scala
 create mode 100644 flink-examples/flink-examples-table/src/main/scala/org/apache/flink/table/examples/scala/basics/WordCountSQLExample.scala
 delete mode 100644 flink-examples/flink-examples-table/src/main/scala/org/apache/flink/table/examples/scala/basics/WordCountTable.scala
 copy flink-examples/flink-examples-table/src/test/java/org/apache/flink/table/examples/java/basics/{GettingStartedExampleITCase.java => StreamSQLExampleITCase.java} (72%)
 copy flink-examples/flink-examples-table/src/test/java/org/apache/flink/table/examples/java/basics/{GettingStartedExampleITCase.java => WordCountSQLExampleITCase.java} (79%)
 copy flink-examples/flink-examples-table/src/test/java/org/apache/flink/table/examples/scala/basics/{GettingStartedExampleITCase.java => StreamSQLExampleITCase.java} (75%)
 copy flink-examples/flink-examples-table/src/test/java/org/apache/flink/table/examples/scala/basics/{GettingStartedExampleITCase.java => WordCountSQLExampleITCase.java} (79%)