This is an automated email from the ASF dual-hosted git repository.
lzljs3620320 pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from 36e98b3 [FLINK-24947][k8s] Support host network for native K8s
integration
add 25e07a7 [FLINK-25520][Table SQL/API] Implement "ALTER TABLE ...
COMPACT" SQL
add c8dce17 [FLINK-25520][Table SQL/API] Implement ITCase for "ALTER
TABLE ... COMPACT" SQL
No new revisions were added by this update.
Summary of changes:
.../table/api/internal/TableEnvironmentImpl.java | 3 -
.../apache/flink/table/catalog/CatalogManager.java | 20 +
.../flink/table/catalog/ManagedTableListener.java | 23 +
.../table/operations/SourceQueryOperation.java | 17 +
.../operations/ddl/AlterTableCompactOperation.java | 58 ---
flink-table/flink-table-common/pom.xml | 5 +
.../flink/table/factories/ManagedTableFactory.java | 8 +
.../connector/sink/TestManagedCommittable.java | 79 ++++
.../table/connector/sink/TestManagedSink.java | 84 ++++
.../sink/TestManagedSinkCommittableSerializer.java | 150 +++++++
.../connector/sink/TestManagedSinkCommitter.java | 147 +++++++
.../connector/sink/TestManagedSinkWriter.java | 73 ++++
.../table/connector/sink/TestManagedTableSink.java | 83 ++++
.../table/connector/source/CompactPartition.java | 166 +++++++
.../table/connector/source/CompactPartitions.java | 149 +++++++
.../source/TestManagedFileSourceReader.java | 35 ++
.../TestManagedFileSourceSplitEnumerator.java | 73 ++++
.../TestManagedFileSourceSplitSerializer.java | 61 +++
.../source/TestManagedIterableSourceSplit.java | 100 +++++
.../table/connector/source/TestManagedSource.java | 94 ++++
.../connector/source/TestManagedTableSource.java | 80 ++++
.../flink/table/factories/FactoryUtilTest.java | 4 +-
.../table/factories/TestManagedTableFactory.java | 190 +++++---
.../operations/SqlToOperationConverter.java | 42 +-
.../planner/plan/QueryOperationConverter.java | 12 +-
.../table/planner/calcite/FlinkRelBuilder.scala | 13 +
.../calcite/FlinkRelOptClusterFactory.scala | 2 +
.../operations/SqlToOperationConverterTest.java | 114 +++--
.../batch/sql/CompactManagedTableITCase.java | 486 +++++++++++++++++++++
.../plan/batch/sql/CompactManagedTableTest.xml | 104 +++++
.../flink/table/api/TableEnvironmentTest.scala | 12 +-
.../plan/batch/sql/CompactManagedTableTest.scala | 100 +++++
.../flink/table/planner/utils/TableTestBase.scala | 28 +-
33 files changed, 2419 insertions(+), 196 deletions(-)
delete mode 100644
flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/operations/ddl/AlterTableCompactOperation.java
create mode 100644
flink-table/flink-table-common/src/test/java/org/apache/flink/table/connector/sink/TestManagedCommittable.java
create mode 100644
flink-table/flink-table-common/src/test/java/org/apache/flink/table/connector/sink/TestManagedSink.java
create mode 100644
flink-table/flink-table-common/src/test/java/org/apache/flink/table/connector/sink/TestManagedSinkCommittableSerializer.java
create mode 100644
flink-table/flink-table-common/src/test/java/org/apache/flink/table/connector/sink/TestManagedSinkCommitter.java
create mode 100644
flink-table/flink-table-common/src/test/java/org/apache/flink/table/connector/sink/TestManagedSinkWriter.java
create mode 100644
flink-table/flink-table-common/src/test/java/org/apache/flink/table/connector/sink/TestManagedTableSink.java
create mode 100644
flink-table/flink-table-common/src/test/java/org/apache/flink/table/connector/source/CompactPartition.java
create mode 100644
flink-table/flink-table-common/src/test/java/org/apache/flink/table/connector/source/CompactPartitions.java
create mode 100644
flink-table/flink-table-common/src/test/java/org/apache/flink/table/connector/source/TestManagedFileSourceReader.java
create mode 100644
flink-table/flink-table-common/src/test/java/org/apache/flink/table/connector/source/TestManagedFileSourceSplitEnumerator.java
create mode 100644
flink-table/flink-table-common/src/test/java/org/apache/flink/table/connector/source/TestManagedFileSourceSplitSerializer.java
create mode 100644
flink-table/flink-table-common/src/test/java/org/apache/flink/table/connector/source/TestManagedIterableSourceSplit.java
create mode 100644
flink-table/flink-table-common/src/test/java/org/apache/flink/table/connector/source/TestManagedSource.java
create mode 100644
flink-table/flink-table-common/src/test/java/org/apache/flink/table/connector/source/TestManagedTableSource.java
create mode 100644
flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/runtime/batch/sql/CompactManagedTableITCase.java
create mode 100644
flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/batch/sql/CompactManagedTableTest.xml
create mode 100644
flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/planner/plan/batch/sql/CompactManagedTableTest.scala
