You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by ja...@apache.org on 2021/03/25 11:47:56 UTC
[flink] branch master updated (08ef809 -> c7c95e5)
This is an automated email from the ASF dual-hosted git repository.
jark pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from 08ef809 [FLINK-21731] Add benchmarks for DefaultScheduler's creation, scheduling and deploying
add c7c95e5 [FLINK-21836][table] Support parsing special commands by introducing ExtendedParser
No new revisions were added by this update.
Summary of changes:
.../table/planner/delegation/hive/HiveParser.java | 2 +-
.../flink/connectors/hive/HiveDialectITCase.java | 21 +++
.../table/client/gateway/local/LocalExecutor.java | 13 +-
.../table/api/internal/TableEnvironmentImpl.java | 2 +-
.../org/apache/flink/table/delegation/Parser.java | 10 ++
.../org/apache/flink/table/delegation/Planner.java | 10 --
.../table/operations/command/ClearOperation.java} | 26 +---
.../table/operations/command/HelpOperation.java} | 25 +---
.../table/operations/command/QuitOperation.java} | 25 +---
.../table/operations/command/ResetOperation.java} | 26 +---
.../table/operations/command/SetOperation.java} | 31 ++--
.../org/apache/flink/table/utils/ParserMock.java | 5 +
.../org/apache/flink/table/utils/PlannerMock.java | 5 -
.../planner/calcite/SqlExprToRexConverterImpl.java | 1 +
.../flink/table/planner/delegation/ParserImpl.java | 45 +++++-
.../table/planner/delegation/PlannerContext.java | 2 +-
.../planner/parse/AbstractRegexParseStrategy.java} | 29 ++--
.../planner/{calcite => parse}/CalciteParser.java | 2 +-
.../parse/ClearOperationParseStrategy.java} | 29 ++--
.../planner/parse/ExtendedParseStrategy.java} | 33 ++---
.../flink/table/planner/parse/ExtendedParser.java | 101 +++++++++++++
.../planner/parse/HelpOperationParseStrategy.java} | 29 ++--
.../planner/parse/QuitOperationParseStrategy.java} | 29 ++--
.../parse/ResetOperationParseStrategy.java} | 29 ++--
.../planner/parse/SetOperationParseStrategy.java | 69 +++++++++
.../table/planner/calcite/FlinkPlannerImpl.scala | 13 +-
.../table/planner/delegation/PlannerBase.scala | 5 -
.../table/planner/delegation/ParserImplTest.java | 162 +++++++++++++++++++++
.../operations/SqlToOperationConverterTest.java | 2 +-
.../codegen/WatermarkGeneratorCodeGenTest.scala | 3 +-
.../table/parse/AbstractRegexParseStrategy.java} | 29 ++--
.../table/{calcite => parse}/CalciteParser.java | 2 +-
.../table/parse/ClearOperationParseStrategy.java} | 29 ++--
.../flink/table/parse/ExtendedParseStrategy.java} | 33 ++---
.../apache/flink/table/parse/ExtendedParser.java | 100 +++++++++++++
.../table/parse/HelpOperationParseStrategy.java} | 29 ++--
.../table/parse/QuitOperationParseStrategy.java} | 29 ++--
.../table/parse/ResetOperationParseStrategy.java} | 29 ++--
.../table/parse/SetOperationParseStrategy.java | 69 +++++++++
.../org/apache/flink/table/planner/ParserImpl.java | 45 +++++-
.../planner/PlanningConfigurationBuilder.java | 2 +-
.../flink/table/api/internal/TableEnvImpl.scala | 11 +-
.../flink/table/calcite/FlinkPlannerImpl.scala | 12 +-
.../apache/flink/table/planner/StreamPlanner.scala | 9 +-
.../table/sqlexec/SqlToOperationConverterTest.java | 73 +++++++++-
.../expressions/utils/ExpressionTestBase.scala | 3 +-
46 files changed, 925 insertions(+), 363 deletions(-)
copy flink-table/flink-table-api-java/src/{test/java/org/apache/flink/table/utils/ParserMock.java => main/java/org/apache/flink/table/operations/command/ClearOperation.java} (55%)
copy flink-table/flink-table-api-java/src/{test/java/org/apache/flink/table/utils/ParserMock.java => main/java/org/apache/flink/table/operations/command/HelpOperation.java} (55%)
copy flink-table/flink-table-api-java/src/{test/java/org/apache/flink/table/utils/ParserMock.java => main/java/org/apache/flink/table/operations/command/QuitOperation.java} (55%)
copy flink-table/flink-table-api-java/src/{test/java/org/apache/flink/table/utils/ParserMock.java => main/java/org/apache/flink/table/operations/command/ResetOperation.java} (55%)
copy flink-table/flink-table-api-java/src/{test/java/org/apache/flink/table/utils/ParserMock.java => main/java/org/apache/flink/table/operations/command/SetOperation.java} (56%)
copy flink-table/{flink-table-api-java/src/test/java/org/apache/flink/table/utils/ParserMock.java => flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/parse/AbstractRegexParseStrategy.java} (55%)
rename flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/{calcite => parse}/CalciteParser.java (99%)
copy flink-table/{flink-table-api-java/src/test/java/org/apache/flink/table/utils/ParserMock.java => flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/parse/ClearOperationParseStrategy.java} (56%)
copy flink-table/{flink-table-api-java/src/test/java/org/apache/flink/table/utils/ParserMock.java => flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/parse/ExtendedParseStrategy.java} (54%)
create mode 100644 flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/parse/ExtendedParser.java
copy flink-table/{flink-table-api-java/src/test/java/org/apache/flink/table/utils/ParserMock.java => flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/parse/HelpOperationParseStrategy.java} (56%)
copy flink-table/{flink-table-api-java/src/test/java/org/apache/flink/table/utils/ParserMock.java => flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/parse/QuitOperationParseStrategy.java} (56%)
copy flink-table/{flink-table-api-java/src/test/java/org/apache/flink/table/utils/ParserMock.java => flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/parse/ResetOperationParseStrategy.java} (56%)
create mode 100644 flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/parse/SetOperationParseStrategy.java
create mode 100644 flink-table/flink-table-planner-blink/src/test/java/org/apache/flink/table/planner/delegation/ParserImplTest.java
copy flink-table/{flink-table-api-java/src/test/java/org/apache/flink/table/utils/ParserMock.java => flink-table-planner/src/main/java/org/apache/flink/table/parse/AbstractRegexParseStrategy.java} (55%)
rename flink-table/flink-table-planner/src/main/java/org/apache/flink/table/{calcite => parse}/CalciteParser.java (98%)
copy flink-table/{flink-table-api-java/src/test/java/org/apache/flink/table/utils/ParserMock.java => flink-table-planner/src/main/java/org/apache/flink/table/parse/ClearOperationParseStrategy.java} (56%)
copy flink-table/{flink-table-api-java/src/test/java/org/apache/flink/table/utils/ParserMock.java => flink-table-planner/src/main/java/org/apache/flink/table/parse/ExtendedParseStrategy.java} (54%)
create mode 100644 flink-table/flink-table-planner/src/main/java/org/apache/flink/table/parse/ExtendedParser.java
copy flink-table/{flink-table-api-java/src/test/java/org/apache/flink/table/utils/ParserMock.java => flink-table-planner/src/main/java/org/apache/flink/table/parse/HelpOperationParseStrategy.java} (56%)
copy flink-table/{flink-table-api-java/src/test/java/org/apache/flink/table/utils/ParserMock.java => flink-table-planner/src/main/java/org/apache/flink/table/parse/QuitOperationParseStrategy.java} (56%)
copy flink-table/{flink-table-api-java/src/test/java/org/apache/flink/table/utils/ParserMock.java => flink-table-planner/src/main/java/org/apache/flink/table/parse/ResetOperationParseStrategy.java} (56%)
create mode 100644 flink-table/flink-table-planner/src/main/java/org/apache/flink/table/parse/SetOperationParseStrategy.java