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 6836184 [FLINK-19599][table] Introduce Filesystem format factories to
integrate new FileSource to table
add 2bbbbc0 [FLINK-19766][table-runtime] Introduce File streaming
compaction operators
No new revisions were added by this update.
Summary of changes:
.../stream/compact/CompactBucketWriter.java | 84 +++++++
.../stream/compact/CompactBulkReader.java | 82 ++++++
.../filesystem/stream/compact/CompactContext.java | 88 +++++++
.../stream/compact/CompactCoordinator.java | 199 +++++++++++++++
.../filesystem/stream/compact/CompactMessages.java | 166 ++++++++++++
.../filesystem/stream/compact/CompactOperator.java | 280 +++++++++++++++++++++
.../filesystem/stream/compact/CompactReader.java | 42 ++++
.../filesystem/stream/compact/CompactWriter.java | 43 ++++
.../flink/table/runtime/util/BinPacking.java | 93 +++++++
.../stream/compact/AbstractCompactTestBase.java | 61 +++++
.../stream/compact/CompactCoordinatorTest.java | 141 +++++++++++
.../stream/compact/CompactOperatorTest.java | 192 ++++++++++++++
.../filesystem/stream/compact/TestByteFormat.java | 64 +++++
.../flink/table/runtime/util/BinPackingTest.java | 69 +++++
14 files changed, 1604 insertions(+)
create mode 100644
flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/filesystem/stream/compact/CompactBucketWriter.java
create mode 100644
flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/filesystem/stream/compact/CompactBulkReader.java
create mode 100644
flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/filesystem/stream/compact/CompactContext.java
create mode 100644
flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/filesystem/stream/compact/CompactCoordinator.java
create mode 100644
flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/filesystem/stream/compact/CompactMessages.java
create mode 100644
flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/filesystem/stream/compact/CompactOperator.java
create mode 100644
flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/filesystem/stream/compact/CompactReader.java
create mode 100644
flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/filesystem/stream/compact/CompactWriter.java
create mode 100644
flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/util/BinPacking.java
create mode 100644
flink-table/flink-table-runtime-blink/src/test/java/org/apache/flink/table/filesystem/stream/compact/AbstractCompactTestBase.java
create mode 100644
flink-table/flink-table-runtime-blink/src/test/java/org/apache/flink/table/filesystem/stream/compact/CompactCoordinatorTest.java
create mode 100644
flink-table/flink-table-runtime-blink/src/test/java/org/apache/flink/table/filesystem/stream/compact/CompactOperatorTest.java
create mode 100644
flink-table/flink-table-runtime-blink/src/test/java/org/apache/flink/table/filesystem/stream/compact/TestByteFormat.java
create mode 100644
flink-table/flink-table-runtime-blink/src/test/java/org/apache/flink/table/runtime/util/BinPackingTest.java
