This is an automated email from the ASF dual-hosted git repository.
czweng pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/paimon.git
from 716a9cff90 [core] Introduce minRowId and maxRowId to ManifestList file
(#6661)
add 3dc8d4fad2 [core] Abstract LookupSerializerFactory and extract classes
from LookupLevels (#6659)
No new revisions were added by this update.
Summary of changes:
.../org/apache/paimon/mergetree/LookupFile.java | 9 +-
.../org/apache/paimon/mergetree/LookupLevels.java | 253 +++++----------------
.../LookupChangelogMergeFunctionWrapper.java | 20 +-
.../compact/LookupMergeTreeCompactRewriter.java | 1 +
.../lookup/DefaultLookupSerializerFactory.java | 52 +++++
.../paimon/mergetree/lookup/FilePosition.java | 22 +-
.../lookup/LookupSerializerFactory.java} | 32 +--
.../mergetree/lookup/PersistEmptyProcessor.java | 61 +++++
.../mergetree/lookup/PersistPositionProcessor.java | 73 ++++++
.../lookup/PersistProcessor.java} | 34 +--
.../lookup/PersistValueAndPosProcessor.java | 95 ++++++++
.../mergetree/lookup/PersistValueProcessor.java | 83 +++++++
.../mergetree/lookup/PositionedKeyValue.java | 32 ++-
.../mergetree/lookup/RemoteFileDownloader.java | 13 +-
.../RemoteLookupFileManager.java | 26 +--
.../paimon/operation/KeyValueFileStoreWrite.java | 49 ++--
.../apache/paimon/table/query/LocalTableQuery.java | 9 +-
.../paimon/mergetree/ContainsLevelsTest.java | 7 +-
.../apache/paimon/mergetree/LookupLevelsTest.java | 7 +-
19 files changed, 560 insertions(+), 318 deletions(-)
create mode 100644
paimon-core/src/main/java/org/apache/paimon/mergetree/lookup/DefaultLookupSerializerFactory.java
copy
paimon-common/src/main/java/org/apache/paimon/utils/ReuseByteArrayOutputStream.java
=>
paimon-core/src/main/java/org/apache/paimon/mergetree/lookup/FilePosition.java
(65%)
copy
paimon-core/src/main/java/org/apache/paimon/{partition/PartitionExpireStrategyFactory.java
=> mergetree/lookup/LookupSerializerFactory.java} (60%)
create mode 100644
paimon-core/src/main/java/org/apache/paimon/mergetree/lookup/PersistEmptyProcessor.java
create mode 100644
paimon-core/src/main/java/org/apache/paimon/mergetree/lookup/PersistPositionProcessor.java
copy
paimon-core/src/main/java/org/apache/paimon/{utils/IntObjectSerializer.java =>
mergetree/lookup/PersistProcessor.java} (56%)
create mode 100644
paimon-core/src/main/java/org/apache/paimon/mergetree/lookup/PersistValueAndPosProcessor.java
create mode 100644
paimon-core/src/main/java/org/apache/paimon/mergetree/lookup/PersistValueProcessor.java
copy
paimon-common/src/main/java/org/apache/paimon/globalindex/GlobalIndexMeta.java
=>
paimon-core/src/main/java/org/apache/paimon/mergetree/lookup/PositionedKeyValue.java
(60%)
copy
paimon-api/src/main/java/org/apache/paimon/rest/responses/PagedResponse.java =>
paimon-core/src/main/java/org/apache/paimon/mergetree/lookup/RemoteFileDownloader.java
(74%)
rename paimon-core/src/main/java/org/apache/paimon/mergetree/{compact =>
lookup}/RemoteLookupFileManager.java (81%)
