From 1165438a2945d4dfb54e2e3152eac7e34026f75f Mon Sep 17 00:00:00 2001 From: ipolyzos Date: Thu, 28 Aug 2025 12:47:42 +0300 Subject: [PATCH 01/27] Add Compacted in LogFormat --- .../src/main/java/org/apache/fluss/metadata/LogFormat.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/fluss-common/src/main/java/org/apache/fluss/metadata/LogFormat.java b/fluss-common/src/main/java/org/apache/fluss/metadata/LogFormat.java index b5f460162f..9923b611fa 100644 --- a/fluss-common/src/main/java/org/apache/fluss/metadata/LogFormat.java +++ b/fluss-common/src/main/java/org/apache/fluss/metadata/LogFormat.java @@ -73,4 +73,4 @@ public static LogFormat fromString(String format) { throw new IllegalArgumentException("Unsupported log format: " + format); } } -} +} \ No newline at end of file From d0698ae86ab8e8c98f0d6cc9b41cc58bd59526f6 Mon Sep 17 00:00:00 2001 From: ipolyzos Date: Sat, 30 Aug 2025 09:26:52 +0300 Subject: [PATCH 02/27] Introduce CompactedLogRecord and related functionality --- .idea/vcs.xml | 4 +-- .../fluss/record/CompactedLogRecord.java | 33 +++++++++++++++++-- 2 files changed, 33 insertions(+), 4 deletions(-) diff --git a/.idea/vcs.xml b/.idea/vcs.xml index b0576b2675..32ad229349 100644 --- a/.idea/vcs.xml +++ b/.idea/vcs.xml @@ -15,6 +15,6 @@ - + - + \ No newline at end of file diff --git a/fluss-common/src/main/java/org/apache/fluss/record/CompactedLogRecord.java b/fluss-common/src/main/java/org/apache/fluss/record/CompactedLogRecord.java index fb7f2f3141..7d6a24b45e 100644 --- a/fluss-common/src/main/java/org/apache/fluss/record/CompactedLogRecord.java +++ b/fluss-common/src/main/java/org/apache/fluss/record/CompactedLogRecord.java @@ -32,10 +32,11 @@ import java.io.IOException; import static org.apache.fluss.record.LogRecordBatchFormat.LENGTH_LENGTH; - /** * An immutable log record for {@link CompactedRow} which can be directly persisted. The on-wire * schema is identical to IndexedLogRecord but the row payload uses the CompactedRow binary format: + * An immutable log record for @CompactedRow which can be directly persisted. The on-wire schema is + * identical to IndexedLogRecord but the row payload uses the CompactedRow binary format: * *