This is an automated email from the ASF dual-hosted git repository.
ipolyzos pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/fluss.git
omit 133933d21 [spark]fix
omit c024481c6 [spark] Rename module "fluss-connector-spark" to
"fluss-spark"
omit 5aae7bc4e [connector-spark] support partition manager
omit 4eb79f7e4 [connector-spark] some fix
omit af1d28827 [license] Update License Copyright year
omit 5989ff3a1 [connector] Support spark catalog and introduce some basic
classes to support spark read and write
omit ad165a428 [connector] support spark catalog
This update removed existing revisions from the reference, leaving the
reference pointing at a previous point in the repository history.
* -- * -- N refs/heads/main (d88c76ce8)
\
O -- O -- O (133933d21)
Any revisions marked "omit" are not gone; other references still
refer to them. Any revisions marked "discard" are gone forever.
No new revisions were added by this update.
Summary of changes:
.../alibaba/fluss/client/table/scanner/Scan.java | 82 -----
.../fluss/client/table/scanner/TableScan.java | 138 --------
.../client/table/scanner/batch/BatchScanUtils.java | 107 ------
.../client/table/scanner/batch/BatchScanner.java | 52 ---
.../table/scanner/batch/LimitBatchScanner.java | 182 ----------
.../scanner/batch/KvSnapshotBatchScanner.java | 40 +--
.../table/scanner/batch/SnapshotFilesReader.java | 39 +--
.../client/table/scanner/log/BucketScanStatus.java | 4 -
.../client/table/scanner/log/CompletedFetch.java | 22 --
.../table/scanner/log/CompletedPendingFetch.java | 4 -
.../client/table/scanner/log/LogFetchBuffer.java | 4 -
.../table/scanner/log/LogFetchCollector.java | 18 -
.../fluss/client/table/scanner/log/LogFetcher.java | 62 ----
.../fluss/client/table/scanner/log/LogScan.java | 4 -
.../fluss/client/table/scanner/log/LogScanner.java | 4 -
.../client/table/scanner/log/LogScannerImpl.java | 18 -
.../client/table/scanner/log/LogScannerStatus.java | 4 -
.../client/table/scanner/log/PendingFetch.java | 4 -
.../table/scanner/log/RemoteCompletedFetch.java | 10 -
.../table/scanner/log/RemoteLogDownloadFuture.java | 4 -
.../table/scanner/log/RemoteLogDownloader.java | 23 --
.../table/scanner/log/RemotePendingFetch.java | 9 -
.../client/table/scanner/log/ScanRecords.java | 9 -
.../client/table/writer/AbstractTableWriter.java | 39 +--
.../fluss/client/lookup/LookupQueueTest.java | 65 ----
.../alibaba/fluss/bucketing/BucketingFunction.java | 45 ---
.../fluss/bucketing/FlussBucketingFunction.java | 42 ---
.../fluss/bucketing/PaimonBucketingFunction.java | 27 --
.../fluss/compression/ArrowCompressionFactory.java | 81 -----
.../fluss/compression/ArrowCompressionInfo.java | 83 -----
.../ArrowCompressionRatioEstimator.java | 68 ----
.../fluss/compression/ArrowCompressionType.java | 33 --
.../compression/FlussLZ4BlockInputStream.java | 305 ----------------
.../compression/FlussLZ4BlockOutputStream.java | 386 ---------------------
.../compression/Lz4ArrowCompressionCodec.java | 98 ------
.../compression/ZstdArrowCompressionCodec.java | 121 -------
.../java/org/apache/fluss/cluster/ServerNode.java | 2 -
.../record/bytesview/MemorySegmentBytesView.java | 2 -
.../fluss/row/encode/CompactedKeyEncoder.java | 46 +--
.../org/apache/fluss/utils/MurmurHashUtils.java | 2 -
.../java/org/apache/fluss/utils/crc/Crc32C.java | 2 -
.../compression/ArrowCompressionCodecTest.java | 284 ---------------
.../ArrowCompressionRatioEstimatorTest.java | 66 ----
.../fluss/connector/flink/row/FlinkAsFlussRow.java | 134 -------
.../fluss/connector/flink/sink/FlinkSink.java | 126 -------
.../connector/flink/row/FlinkAsFlussRowTest.java | 155 ---------
.../org.junit.jupiter.api.extension.Extension | 17 -
fluss-dist/pom.xml | 12 -
.../fluss/flink/sink/writer/FlinkSinkWriter.java | 69 ----
fluss-lake/fluss-lake-common/pom.xml | 31 --
.../operator/PaimonMultiWriterOperatorFactory.java | 70 ----
.../paimon/source/state/SourceSplitStateTest.java | 97 ------
.../paimon/testutils/TestingDatabaseSyncSink.java | 174 ----------
.../org.junit.jupiter.api.extension.Extension | 17 -
.../server/kv/rowmerger/DefaultRowMerger.java | 107 ------
.../server/kv/rowmerger/FirstRowRowMerger.java | 59 ----
.../fluss/server/kv/rowmerger/RowMerger.java | 88 -----
.../server/kv/rowmerger/VersionedRowMerger.java | 126 -------
.../kv/rowmerger/VersionedRowMergerTest.java | 185 ----------
59 files changed, 21 insertions(+), 4086 deletions(-)
delete mode 100644
fluss-client/src/main/java/com/alibaba/fluss/client/table/scanner/Scan.java
delete mode 100644
fluss-client/src/main/java/com/alibaba/fluss/client/table/scanner/TableScan.java
delete mode 100644
fluss-client/src/main/java/com/alibaba/fluss/client/table/scanner/batch/BatchScanUtils.java
delete mode 100644
fluss-client/src/main/java/com/alibaba/fluss/client/table/scanner/batch/BatchScanner.java
delete mode 100644
fluss-client/src/main/java/com/alibaba/fluss/client/table/scanner/batch/LimitBatchScanner.java
delete mode 100644
fluss-client/src/test/java/com/alibaba/fluss/client/lookup/LookupQueueTest.java
delete mode 100644
fluss-common/src/main/java/com/alibaba/fluss/bucketing/BucketingFunction.java
delete mode 100644
fluss-common/src/main/java/com/alibaba/fluss/bucketing/FlussBucketingFunction.java
delete mode 100644
fluss-common/src/main/java/com/alibaba/fluss/bucketing/PaimonBucketingFunction.java
delete mode 100644
fluss-common/src/main/java/com/alibaba/fluss/compression/ArrowCompressionFactory.java
delete mode 100644
fluss-common/src/main/java/com/alibaba/fluss/compression/ArrowCompressionInfo.java
delete mode 100644
fluss-common/src/main/java/com/alibaba/fluss/compression/ArrowCompressionRatioEstimator.java
delete mode 100644
fluss-common/src/main/java/com/alibaba/fluss/compression/ArrowCompressionType.java
delete mode 100644
fluss-common/src/main/java/com/alibaba/fluss/compression/FlussLZ4BlockInputStream.java
delete mode 100644
fluss-common/src/main/java/com/alibaba/fluss/compression/FlussLZ4BlockOutputStream.java
delete mode 100644
fluss-common/src/main/java/com/alibaba/fluss/compression/Lz4ArrowCompressionCodec.java
delete mode 100644
fluss-common/src/main/java/com/alibaba/fluss/compression/ZstdArrowCompressionCodec.java
delete mode 100644
fluss-common/src/test/java/com/alibaba/fluss/compression/ArrowCompressionCodecTest.java
delete mode 100644
fluss-common/src/test/java/com/alibaba/fluss/compression/ArrowCompressionRatioEstimatorTest.java
delete mode 100644
fluss-connectors/fluss-connector-flink/src/main/java/com/alibaba/fluss/connector/flink/row/FlinkAsFlussRow.java
delete mode 100644
fluss-connectors/fluss-connector-flink/src/main/java/com/alibaba/fluss/connector/flink/sink/FlinkSink.java
delete mode 100644
fluss-connectors/fluss-connector-flink/src/test/java/com/alibaba/fluss/connector/flink/row/FlinkAsFlussRowTest.java
delete mode 100644
fluss-connectors/fluss-connector-flink/src/test/resources/META-INF/services/org.junit.jupiter.api.extension.Extension
delete mode 100644 fluss-lake/fluss-lake-common/pom.xml
delete mode 100644
fluss-lakehouse/fluss-lakehouse-paimon/src/main/java/com/alibaba/fluss/lakehouse/paimon/sink/operator/PaimonMultiWriterOperatorFactory.java
delete mode 100644
fluss-lakehouse/fluss-lakehouse-paimon/src/test/java/com/alibaba/fluss/lakehouse/paimon/source/state/SourceSplitStateTest.java
delete mode 100644
fluss-lakehouse/fluss-lakehouse-paimon/src/test/java/com/alibaba/fluss/lakehouse/paimon/testutils/TestingDatabaseSyncSink.java
delete mode 100644
fluss-lakehouse/fluss-lakehouse-paimon/src/test/resources/META-INF/services/org.junit.jupiter.api.extension.Extension
delete mode 100644
fluss-server/src/main/java/com/alibaba/fluss/server/kv/rowmerger/DefaultRowMerger.java
delete mode 100644
fluss-server/src/main/java/com/alibaba/fluss/server/kv/rowmerger/FirstRowRowMerger.java
delete mode 100644
fluss-server/src/main/java/com/alibaba/fluss/server/kv/rowmerger/RowMerger.java
delete mode 100644
fluss-server/src/main/java/com/alibaba/fluss/server/kv/rowmerger/VersionedRowMerger.java
delete mode 100644
fluss-server/src/test/java/com/alibaba/fluss/server/kv/rowmerger/VersionedRowMergerTest.java
