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 35d3d31 [FLINK-18295][runtime] Change IntermediateDataSet to
explicitly have exactly one consumer vertex
add ccfd13a [FLINK-25128][table-planner][table-runtime] Move aggregate
and table functions with runtime logic in runtime
add 3e93060 [FLINK-25128][table-planner] Fix usage of avatica core
DateTimeUtils class
add 749bb77 [FLINK-25128][table] Reorganize table modules and introduce
flink-table-planner-loader
add fdc53e7 [FLINK-25128][e2e] Update tests to replace the planner jars
whenever necessary to check both planners
No new revisions were added by this update.
Summary of changes:
flink-architecture-tests/pom.xml | 6 +-
.../5b9eed8a-5fb6-4373-98ac-3be2a71941b8 | 3 +
.../7602816f-5c01-4b7a-9e3e-235dfedec245 | 2 +-
.../e5126cae-f3fe-48aa-b6fb-60ae6cc3fcd5 | 27 +-
flink-dist/pom.xml | 53 +++-
flink-dist/src/main/assemblies/bin.xml | 26 +-
flink-dist/src/main/assemblies/opt.xml | 19 +-
flink-docs/pom.xml | 2 +-
.../flink-sql-client-test/pom.xml | 2 +-
.../flink-stream-sql-test/pom.xml | 11 +-
flink-end-to-end-tests/flink-tpcds-test/pom.xml | 14 +-
flink-end-to-end-tests/run-nightly-tests.sh | 3 +-
flink-end-to-end-tests/test-scripts/common.sh | 10 +
.../test-scripts/test_streaming_sql.sh | 6 +
flink-examples/flink-examples-table/pom.xml | 23 +-
flink-python/apache-flink-libraries/setup.py | 2 +-
flink-table/README.md | 67 +++++
flink-table/flink-sql-client/pom.xml | 57 +---
.../pom.xml | 63 ++---
.../src/main/resources/META-INF/NOTICE | 10 +
.../main/resources/META-INF/licenses/LICENSE.icu4j | 0
flink-table/flink-table-common/pom.xml | 2 -
flink-table/flink-table-planner-loader/pom.xml | 163 +++++++++++
.../table/planner/loader/BaseDelegateFactory.java | 49 ++++
.../planner/loader/DelegateExecutorFactory.java | 45 +++
.../loader/DelegateExpressionParserFactory.java | 38 +++
.../planner/loader/DelegatePlannerFactory.java | 38 +++
.../flink/table/planner/loader/PlannerModule.java | 144 ++++++++++
.../org.apache.flink.table.factories.Factory | 18 ++
.../flink/table/planner/loader/LoaderITCase.java | 100 +++++++
flink-table/flink-table-planner/pom.xml | 313 +++++++++++----------
.../casting/TimestampToStringCastRule.java | 3 +-
.../plan/nodes/exec/serde/JsonSerdeUtil.java | 2 +
.../plan/nodes/exec/utils/CommonPythonUtil.java | 16 +-
.../src/main/resources/META-INF/NOTICE | 11 -
.../codegen/agg/batch/WindowCodeGenerator.scala | 2 +-
.../table/planner/delegation/PlannerBase.scala | 6 +-
.../planner/plan/utils/AggFunctionFactory.scala | 2 +-
.../planner/plan/utils/SetOpRewriteUtil.scala | 2 +-
.../FirstValueAggFunctionWithOrderTest.java | 1 +
.../FirstValueAggFunctionWithoutOrderTest.java | 1 +
...stValueWithRetractAggFunctionWithOrderTest.java | 3 +-
...alueWithRetractAggFunctionWithoutOrderTest.java | 3 +-
.../functions/aggfunctions/LagAggFunctionTest.java | 1 +
.../LastValueAggFunctionWithOrderTest.java | 1 +
.../LastValueAggFunctionWithoutOrderTest.java | 1 +
...stValueWithRetractAggFunctionWithOrderTest.java | 3 +-
...alueWithRetractAggFunctionWithoutOrderTest.java | 3 +-
.../ListAggWithRetractAggFunctionTest.java | 3 +-
.../ListAggWsWithRetractAggFunctionTest.java | 3 +-
.../MaxWithRetractAggFunctionTest.java | 3 +-
.../MinWithRetractAggFunctionTest.java | 3 +-
.../PushLocalAggIntoTableSourceScanRuleTest.java | 2 +-
.../planner/plan/batch/sql/SetOperatorsTest.xml | 4 +-
.../planner/plan/batch/table/SetOperatorsTest.xml | 4 +-
.../planner/plan/common/PartialInsertTest.xml | 8 +-
.../rules/logical/RewriteIntersectAllRuleTest.xml | 8 +-
.../plan/rules/logical/RewriteMinusAllRuleTest.xml | 8 +-
.../planner/plan/stream/sql/SetOperatorsTest.xml | 4 +-
.../planner/plan/batch/sql/SubplanReuseTest.scala | 2 +-
.../planner/plan/stream/sql/SubplanReuseTest.scala | 2 +-
.../runtime/stream/sql/AggregateITCase.scala | 2 +-
flink-table/flink-table-runtime/pom.xml | 27 +-
.../functions/aggregate}/CollectAggFunction.java | 3 +-
.../aggregate}/FirstValueAggFunction.java | 3 +-
.../FirstValueWithRetractAggFunction.java | 3 +-
.../functions/aggregate}/JsonArrayAggFunction.java | 8 +-
.../aggregate}/JsonObjectAggFunction.java | 6 +-
.../functions/aggregate}/LagAggFunction.java | 3 +-
.../functions/aggregate}/LastValueAggFunction.java | 3 +-
.../LastValueWithRetractAggFunction.java | 3 +-
.../aggregate}/ListAggWithRetractAggFunction.java | 3 +-
.../ListAggWsWithRetractAggFunction.java | 3 +-
.../aggregate}/MaxWithRetractAggFunction.java | 3 +-
.../aggregate}/MinWithRetractAggFunction.java | 3 +-
.../runtime/functions/table}/ReplicateRows.java | 2 +-
.../src/main/resources/META-INF/NOTICE | 2 +
.../resources/META-INF/licenses/LICENSE.janino | 0
flink-table/pom.xml | 3 +-
.../tools/ci/suffixcheck/ScalaSuffixChecker.java | 25 +-
tools/ci/stage.sh | 1 +
81 files changed, 1115 insertions(+), 422 deletions(-)
create mode 100644 flink-table/README.md
rename flink-table/{flink-table-uber => flink-table-api-java-uber}/pom.xml
(61%)
create mode 100644
flink-table/flink-table-api-java-uber/src/main/resources/META-INF/NOTICE
rename flink-table/{flink-table-planner =>
flink-table-api-java-uber}/src/main/resources/META-INF/licenses/LICENSE.icu4j
(100%)
create mode 100644 flink-table/flink-table-planner-loader/pom.xml
create mode 100644
flink-table/flink-table-planner-loader/src/main/java/org/apache/flink/table/planner/loader/BaseDelegateFactory.java
create mode 100644
flink-table/flink-table-planner-loader/src/main/java/org/apache/flink/table/planner/loader/DelegateExecutorFactory.java
create mode 100644
flink-table/flink-table-planner-loader/src/main/java/org/apache/flink/table/planner/loader/DelegateExpressionParserFactory.java
create mode 100644
flink-table/flink-table-planner-loader/src/main/java/org/apache/flink/table/planner/loader/DelegatePlannerFactory.java
create mode 100644
flink-table/flink-table-planner-loader/src/main/java/org/apache/flink/table/planner/loader/PlannerModule.java
create mode 100644
flink-table/flink-table-planner-loader/src/main/resources/META-INF/services/org.apache.flink.table.factories.Factory
create mode 100644
flink-table/flink-table-planner-loader/src/test/java/org/apache/flink/table/planner/loader/LoaderITCase.java
rename
flink-table/{flink-table-planner/src/main/java/org/apache/flink/table/planner/functions/aggfunctions
=>
flink-table-runtime/src/main/java/org/apache/flink/table/runtime/functions/aggregate}/CollectAggFunction.java
(97%)
rename
flink-table/{flink-table-planner/src/main/java/org/apache/flink/table/planner/functions/aggfunctions
=>
flink-table-runtime/src/main/java/org/apache/flink/table/runtime/functions/aggregate}/FirstValueAggFunction.java
(96%)
rename
flink-table/{flink-table-planner/src/main/java/org/apache/flink/table/planner/functions/aggfunctions
=>
flink-table-runtime/src/main/java/org/apache/flink/table/runtime/functions/aggregate}/FirstValueWithRetractAggFunction.java
(98%)
rename
flink-table/{flink-table-planner/src/main/java/org/apache/flink/table/planner/functions/aggfunctions
=>
flink-table-runtime/src/main/java/org/apache/flink/table/runtime/functions/aggregate}/JsonArrayAggFunction.java
(94%)
rename
flink-table/{flink-table-planner/src/main/java/org/apache/flink/table/planner/functions/aggfunctions
=>
flink-table-runtime/src/main/java/org/apache/flink/table/runtime/functions/aggregate}/JsonObjectAggFunction.java
(96%)
rename
flink-table/{flink-table-planner/src/main/java/org/apache/flink/table/planner/functions/aggfunctions
=>
flink-table-runtime/src/main/java/org/apache/flink/table/runtime/functions/aggregate}/LagAggFunction.java
(97%)
rename
flink-table/{flink-table-planner/src/main/java/org/apache/flink/table/planner/functions/aggfunctions
=>
flink-table-runtime/src/main/java/org/apache/flink/table/runtime/functions/aggregate}/LastValueAggFunction.java
(96%)
rename
flink-table/{flink-table-planner/src/main/java/org/apache/flink/table/planner/functions/aggfunctions
=>
flink-table-runtime/src/main/java/org/apache/flink/table/runtime/functions/aggregate}/LastValueWithRetractAggFunction.java
(98%)
rename
flink-table/{flink-table-planner/src/main/java/org/apache/flink/table/planner/functions/aggfunctions
=>
flink-table-runtime/src/main/java/org/apache/flink/table/runtime/functions/aggregate}/ListAggWithRetractAggFunction.java
(97%)
rename
flink-table/{flink-table-planner/src/main/java/org/apache/flink/table/planner/functions/aggfunctions
=>
flink-table-runtime/src/main/java/org/apache/flink/table/runtime/functions/aggregate}/ListAggWsWithRetractAggFunction.java
(98%)
rename
flink-table/{flink-table-planner/src/main/java/org/apache/flink/table/planner/functions/aggfunctions
=>
flink-table-runtime/src/main/java/org/apache/flink/table/runtime/functions/aggregate}/MaxWithRetractAggFunction.java
(98%)
rename
flink-table/{flink-table-planner/src/main/java/org/apache/flink/table/planner/functions/aggfunctions
=>
flink-table-runtime/src/main/java/org/apache/flink/table/runtime/functions/aggregate}/MinWithRetractAggFunction.java
(98%)
rename
flink-table/{flink-table-planner/src/main/java/org/apache/flink/table/planner/functions/tablefunctions
=>
flink-table-runtime/src/main/java/org/apache/flink/table/runtime/functions/table}/ReplicateRows.java
(97%)
rename flink-table/{flink-table-planner =>
flink-table-runtime}/src/main/resources/META-INF/licenses/LICENSE.janino (100%)
