You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by tw...@apache.org on 2022/03/02 13:50:16 UTC
[flink] branch master updated (449d968 -> 0bc50ff)
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 449d968 [FLINK-26286][kubernetes] Introduce idempotent KubernetesStateHandleStore.
add 0bc50ff [FLINK-26131][table] Let CompiledPlan implement Executable and simplify TableEnvironment
No new revisions were added by this update.
Summary of changes:
.../flink/formats/csv/TableCsvFormatITCase.java | 28 ++------
.../org/apache/flink/table/api/CompiledPlan.java | 9 +--
.../apache/flink/table/api/TableEnvironment.java | 43 ++----------
.../flink/table/api/internal/CompiledPlanImpl.java | 82 ++++++++++++++++++++++
.../table/api/internal/TableEnvironmentImpl.java | 23 +++---
.../api/internal/TableEnvironmentInternal.java | 12 ++--
.../InternalPlan.java} | 25 +++++--
.../org/apache/flink/table/delegation/Planner.java | 10 ++-
.../org/apache/flink/table/utils/PlannerMock.java | 11 ++-
...ledPlan.java => ExecNodeGraphInternalPlan.java} | 25 ++-----
.../table/planner/delegation/BatchPlanner.scala | 12 ++--
.../table/planner/delegation/StreamPlanner.scala | 31 ++++----
.../apache/flink/table/api/CompiledPlanITCase.java | 11 ++-
.../table/api/internal/CompiledPlanUtils.java | 46 ++++++++++++
.../plan/nodes/exec/TransformationsTest.java | 8 +--
.../jsonplan/DeduplicationJsonPlanITCase.java | 2 +-
.../table/planner/utils/JsonPlanTestBase.java | 10 +--
17 files changed, 231 insertions(+), 157 deletions(-)
create mode 100644 flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/internal/CompiledPlanImpl.java
rename flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/{api/internal/CompiledPlanInternal.java => delegation/InternalPlan.java} (55%)
rename flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/{ExecNodeGraphCompiledPlan.java => ExecNodeGraphInternalPlan.java} (81%)
create mode 100644 flink-table/flink-table-planner/src/test/java/org/apache/flink/table/api/internal/CompiledPlanUtils.java