You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by go...@apache.org on 2022/02/18 14:04:48 UTC

[flink] branch master updated (9f60c50 -> 80786b2)

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

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


    from 9f60c50  [FLINK-24407][doc-zh] Fix the broken links in Chinese document of Pulsar connector
     add 2c3b69a  [FLINK-25600][sql-client] Support new statement set syntax in sql client
     add 80786b2  [FLINK-25600][docs] Update doc about new statement set syntax

No new revisions were added by this update.

Summary of changes:
 docs/content.zh/docs/dev/table/sql/explain.md      |  11 +-
 docs/content.zh/docs/dev/table/sql/insert.md       |  41 ++-
 docs/content.zh/docs/dev/table/sqlClient.md        |  27 +-
 docs/content/docs/dev/table/sql/explain.md         |  12 +-
 docs/content/docs/dev/table/sql/insert.md          |  44 ++-
 docs/content/docs/dev/table/sqlClient.md           |  27 +-
 .../apache/flink/table/client/cli/CliClient.java   | 128 +++++----
 .../table/client/cli/CliStatementSplitter.java     |  76 -----
 .../flink/table/client/cli/SqlCommandParser.java}  |  19 +-
 .../table/client/cli/SqlCommandParserImpl.java}    |  38 ++-
 .../flink/table/client/cli/SqlCompleter.java       |   6 -
 .../flink/table/client/cli/SqlMultiLineParser.java |  71 ++++-
 .../flink/table/client/cli/CliClientITCase.java    |  22 +-
 .../client/cli/CliClientMultiStatementITTest.java  |  78 ++++++
 .../flink/table/client/cli/CliClientTest.java      |  57 ++--
 .../table/client/cli/CliStatementSplitterTest.java |  86 ------
 .../table/client/cli/utils/SqlScriptReader.java    |  25 +-
 .../src/test/resources/sql/_HOW_TO_USE.md          |   7 +-
 .../src/test/resources/sql/catalog_database.q      |   1 +
 .../src/test/resources/sql_multi/statement_set.q   | 308 +++++++++++++++++++++
 ...erException.java => SqlParserEOFException.java} |  12 +-
 .../flink/table/planner/delegation/ParserImpl.java |  15 +-
 .../flink/table/planner/parse/CalciteParser.java   |  30 +-
 .../planner/parse/ClearOperationParseStrategy.java |   2 +-
 .../planner/parse/HelpOperationParseStrategy.java  |   2 +-
 .../planner/parse/QuitOperationParseStrategy.java  |   2 +-
 .../planner/parse/ResetOperationParseStrategy.java |   2 +-
 .../planner/parse/SetOperationParseStrategy.java   |   2 +-
 .../table/planner/delegation/ParserImplTest.java   |  17 ++
 .../parse/ResetOperationParseStrategyTest.java     |  11 +-
 .../parse/SetOperationParseStrategyTest.java       |  35 ++-
 31 files changed, 840 insertions(+), 374 deletions(-)
 delete mode 100644 flink-table/flink-sql-client/src/main/java/org/apache/flink/table/client/cli/CliStatementSplitter.java
 copy flink-table/{flink-table-api-java/src/main/java/org/apache/flink/table/expressions/resolver/lookups/TableReferenceLookup.java => flink-sql-client/src/main/java/org/apache/flink/table/client/cli/SqlCommandParser.java} (59%)
 copy flink-table/{flink-table-api-java/src/main/java/org/apache/flink/table/operations/command/ResetOperation.java => flink-sql-client/src/main/java/org/apache/flink/table/client/cli/SqlCommandParserImpl.java} (51%)
 create mode 100644 flink-table/flink-sql-client/src/test/java/org/apache/flink/table/client/cli/CliClientMultiStatementITTest.java
 delete mode 100644 flink-table/flink-sql-client/src/test/java/org/apache/flink/table/client/cli/CliStatementSplitterTest.java
 create mode 100644 flink-table/flink-sql-client/src/test/resources/sql_multi/statement_set.q
 copy flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/{SqlParserException.java => SqlParserEOFException.java} (76%)