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
