This is an automated email from the ASF dual-hosted git repository.
kurt pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from a815b7b [hotfix][JavaDocs] Correct docs in MemoryStateBackend
add 9e0b249 [FLINK-14665][table-planner-blink] Support computed column in
blink-planner
No new revisions were added by this update.
Summary of changes:
.../table/planner/calcite/FlinkToRelContext.java | 29 +-
.../catalog/QueryOperationCatalogViewTable.java | 4 +-
.../table/planner/delegation/PlannerContext.java | 2 +-
.../operations/SqlToOperationConverter.java | 43 ++-
.../table/planner/calcite/FlinkPlannerImpl.scala | 60 ++--
.../logical/FlinkLogicalTableSourceScan.scala | 6 +-
.../nodes/physical/PhysicalTableSourceScan.scala | 6 +-
.../planner/plan/schema/FlinkRelOptTable.scala | 57 +++-
.../planner/plan/schema/TableSourceTable.scala | 3 +-
.../table/planner/sources/TableSourceUtil.scala | 15 +-
.../operations/SqlToOperationConverterTest.java | 45 +++
.../testGetDigestWithDynamicFunctionView.out | 3 -
.../apache/flink/table/api/stream/ExplainTest.xml | 162 +++++------
.../planner/plan/batch/sql/DagOptimizationTest.xml | 154 +++++------
.../table/planner/plan/batch/sql/SinkTest.xml | 18 +-
.../plan/schema/ComputedColumnToRelTest.xml | 67 +++++
.../plan/stream/sql/DagOptimizationTest.xml | 192 ++++++-------
.../plan/stream/sql/MiniBatchIntervalInferTest.xml | 138 +++++----
.../flink/table/api/TableEnvironmentTest.scala | 7 +-
.../table/planner/catalog/CatalogTableITCase.scala | 308 +++++++++++++++++++--
.../codegen/WatermarkGeneratorCodeGenTest.scala | 5 +-
.../utils/TestCollectionTableFactory.scala | 14 +-
.../plan/schema/ComputedColumnToRelTest.scala | 191 +++++++++++++
.../planner/plan/utils/FlinkRelOptUtilTest.scala | 19 +-
.../batch/sql/PartitionableSinkITCase.scala | 2 +-
.../batch/sql/agg/AggregateITCaseBase.scala | 4 +-
.../sql/agg/DistinctAggregateITCaseBase.scala | 2 +-
.../runtime/batch/sql/agg/GroupingSetsITCase.scala | 10 +-
.../runtime/batch/sql/join/InnerJoinITCase.scala | 8 +-
.../table/planner/runtime/utils/TestData.scala | 48 ++--
30 files changed, 1091 insertions(+), 531 deletions(-)
copy
flink-runtime/src/main/java/org/apache/flink/runtime/state/KeyGroupsList.java
=>
flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/calcite/FlinkToRelContext.java
(51%)
create mode 100644
flink-table/flink-table-planner-blink/src/test/resources/org/apache/flink/table/planner/plan/schema/ComputedColumnToRelTest.xml
create mode 100644
flink-table/flink-table-planner-blink/src/test/scala/org/apache/flink/table/planner/plan/schema/ComputedColumnToRelTest.scala
