From 6712c409ec976bf51ab8b54d7a2e6774a6d038c2 Mon Sep 17 00:00:00 2001 From: yejunhao Date: Tue, 2 Apr 2024 16:45:10 +0800 Subject: [PATCH] fix comment --- .../main/java/org/apache/paimon/disk/ExternalBuffer.java | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/paimon-core/src/main/java/org/apache/paimon/disk/ExternalBuffer.java b/paimon-core/src/main/java/org/apache/paimon/disk/ExternalBuffer.java index 9df2845c9b69..0d2dc2e7b78d 100644 --- a/paimon-core/src/main/java/org/apache/paimon/disk/ExternalBuffer.java +++ b/paimon-core/src/main/java/org/apache/paimon/disk/ExternalBuffer.java @@ -19,7 +19,7 @@ package org.apache.paimon.disk; import org.apache.paimon.annotation.VisibleForTesting; -import org.apache.paimon.compression.Lz4BlockCompressionFactory; +import org.apache.paimon.compression.BlockCompressionFactory; import org.apache.paimon.data.BinaryRow; import org.apache.paimon.data.InternalRow; import org.apache.paimon.data.serializer.AbstractRowDataSerializer; @@ -44,8 +44,8 @@ public class ExternalBuffer implements RowBuffer { private static final Logger LOG = LoggerFactory.getLogger(ExternalBuffer.class); - private static final Lz4BlockCompressionFactory compactionFactory = - new Lz4BlockCompressionFactory(); + private static final BlockCompressionFactory compactionFactory = + BlockCompressionFactory.create("LZ4"); private final IOManager ioManager; private final MemorySegmentPool pool;