diff options
author | Bjørn Christian Seime <bjorn.christian@seime.no> | 2021-01-19 19:19:33 +0100 |
---|---|---|
committer | GitHub <noreply@github.com> | 2021-01-19 19:19:33 +0100 |
commit | 3e62c6ae4a6d85699f1af6eeff533aef30493f20 (patch) | |
tree | ab57470816ce664a4cd37e5c01f90035131b3c99 /vespajlib/src/main/java/com/yahoo/compress/ZstdCompressor.java | |
parent | 6f326f6cc056dc46f5538a8a186c8420b0379edc (diff) |
Revert "Bjorncs/zstd java"
Diffstat (limited to 'vespajlib/src/main/java/com/yahoo/compress/ZstdCompressor.java')
-rw-r--r-- | vespajlib/src/main/java/com/yahoo/compress/ZstdCompressor.java | 51 |
1 files changed, 0 insertions, 51 deletions
diff --git a/vespajlib/src/main/java/com/yahoo/compress/ZstdCompressor.java b/vespajlib/src/main/java/com/yahoo/compress/ZstdCompressor.java deleted file mode 100644 index 72ccb730db7..00000000000 --- a/vespajlib/src/main/java/com/yahoo/compress/ZstdCompressor.java +++ /dev/null @@ -1,51 +0,0 @@ -// Copyright Verizon Media. Licensed under the terms of the Apache 2.0 license. See LICENSE in the project root. -package com.yahoo.compress; - -import java.util.Arrays; - -/** - * Frame based Zstd compressor (https://github.com/facebook/zstd) - * Implemented based on https://github.com/airlift/aircompressor - a pure Java implementation (no JNI). - * - * @author bjorncs - */ -public class ZstdCompressor { - - private static final io.airlift.compress.zstd.ZstdCompressor compressor = new io.airlift.compress.zstd.ZstdCompressor(); - private static final io.airlift.compress.zstd.ZstdDecompressor decompressor = new io.airlift.compress.zstd.ZstdDecompressor(); - - public byte[] compress(byte[] input, int inputOffset, int inputLength) { - int maxCompressedLength = getMaxCompressedLength(inputLength); - byte[] output = new byte[maxCompressedLength]; - int compressedLength = compress(input, inputOffset, inputLength, output, 0, maxCompressedLength); - return Arrays.copyOf(output, compressedLength); - } - - public int compress(byte[] input, int inputOffset, int inputLength, byte[] output, int outputOffset, int maxOutputLength) { - return compressor.compress(input, inputOffset, inputLength, output, outputOffset, maxOutputLength); - } - - /** - * Note: - * Implementation assumes single frame (since {@link #getDecompressedLength(byte[], int, int)} only includes the first frame) - * The {@link #decompress(byte[], int, int, byte[], int, int)} overload will try to decompress all frame, causing the output buffer to overflow. - */ - public byte[] decompress(byte[] input, int inputOffset, int inputLength) { - int decompressedLength = getDecompressedLength(input, inputOffset, inputLength); - byte[] output = new byte[decompressedLength]; - decompress(input, inputOffset, inputLength, output, 0, decompressedLength); - return output; - } - - public int decompress(byte[] input, int inputOffset, int inputLength, byte[] output, int outputOffset, int maxOutputLength) { - return decompressor.decompress(input, inputOffset, inputLength, output, outputOffset, maxOutputLength); - } - - public static int getMaxCompressedLength(int uncompressedLength) { - return compressor.maxCompressedLength(uncompressedLength); - } - - public static int getDecompressedLength(byte[] input, int inputOffset, int inputLength) { - return (int) io.airlift.compress.zstd.ZstdDecompressor.getDecompressedSize(input, inputOffset, inputLength); - } -} |