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
