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/02/16 12:54:08 UTC
[flink] branch master updated (85bc4e3 -> 20a1b88)
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 85bc4e3 [FLINK-26119][connectors/common] Switching AsyncSinkWriterStateSerializer from @Internal to @PublicEvolving
add 3868687 [hotfix][table-api-java] Extract explain, execute and compilePlan API capabilities into specific interfaces
add 20a1b88 [FLINK-26089][table-api-java] Introduce TablePipeline
No new revisions were added by this update.
Summary of changes:
.../pyflink/table/tests/test_table_completeness.py | 3 +-
.../table/api/bridge/java/StreamStatementSet.java | 8 ++
.../java/internal/StreamStatementSetImpl.java | 20 +++-
.../org/apache/flink/table/api/Compilable.java | 28 +++--
.../org/apache/flink/table/api/CompiledPlan.java | 16 +--
.../table/api/{ResultKind.java => Executable.java} | 23 ++--
.../api/{PlannerConfig.java => Explainable.java} | 30 +++--
.../org/apache/flink/table/api/StatementSet.java | 133 ++++-----------------
.../java/org/apache/flink/table/api/Table.java | 107 ++++++++++-------
.../api/{PlannerConfig.java => TablePipeline.java} | 24 ++--
.../flink/table/api/internal/StatementSetImpl.java | 65 +++-------
.../apache/flink/table/api/internal/TableImpl.java | 29 ++---
.../table/api/internal/TablePipelineImpl.java | 86 +++++++++++++
.../api/bridge/scala/StreamStatementSet.scala | 6 +-
.../scala/internal/StreamStatementSetImpl.scala | 11 +-
.../apache/flink/table/api/CompiledPlanITCase.java | 15 ++-
.../table/planner/plan/hint/OptionsHintTest.scala | 5 +-
.../runtime/batch/sql/join/JoinITCase.scala | 6 +-
.../flink/table/planner/utils/TableTestBase.scala | 72 +----------
19 files changed, 323 insertions(+), 364 deletions(-)
copy flink-test-utils-parent/flink-connector-test-utils/src/main/java/org/apache/flink/connector/testframe/external/ExternalSystemDataReader.java => flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/Compilable.java (52%)
copy flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/{ResultKind.java => Executable.java} (65%)
copy flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/{PlannerConfig.java => Explainable.java} (54%)
copy flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/{PlannerConfig.java => TablePipeline.java} (65%)
create mode 100644 flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/internal/TablePipelineImpl.java