Skip to content

Commit c4f825c

Browse files
authored
Merge pull request #385 from Natal1a-Chuklina/change-lzo-to-lzop
change LzoOutputStream to LzopOutputStream
2 parents 88678c6 + d168e44 commit c4f825c

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

topic/src/main/java/tech/ydb/topic/utils/Encoder.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -13,8 +13,8 @@
1313
import org.anarres.lzo.LzoAlgorithm;
1414
import org.anarres.lzo.LzoCompressor;
1515
import org.anarres.lzo.LzoLibrary;
16-
import org.anarres.lzo.LzoOutputStream;
1716
import org.anarres.lzo.LzopInputStream;
17+
import org.anarres.lzo.LzopOutputStream;
1818

1919
import tech.ydb.topic.description.Codec;
2020

@@ -64,7 +64,7 @@ private static OutputStream makeOutputStream(Codec codec,
6464
return new ZstdOutputStreamNoFinalizer(byteArrayOutputStream);
6565
case LZOP:
6666
LzoCompressor lzoCompressor = LzoLibrary.getInstance().newCompressor(LzoAlgorithm.LZO1X, null);
67-
return new LzoOutputStream(byteArrayOutputStream, lzoCompressor);
67+
return new LzopOutputStream(byteArrayOutputStream, lzoCompressor);
6868
case CUSTOM:
6969
default:
7070
throw new RuntimeException("Unsupported codec: " + codec);

0 commit comments

Comments
 (0)