summaryrefslogtreecommitdiffstats
path: root/vespajlib/src/main/java/com/yahoo/compress/ZstdCompressor.java
diff options
context:
space:
mode:
authorBjørn Christian Seime <bjorn.christian@seime.no>2021-01-19 19:19:33 +0100
committerGitHub <noreply@github.com>2021-01-19 19:19:33 +0100
commit3e62c6ae4a6d85699f1af6eeff533aef30493f20 (patch)
treeab57470816ce664a4cd37e5c01f90035131b3c99 /vespajlib/src/main/java/com/yahoo/compress/ZstdCompressor.java
parent6f326f6cc056dc46f5538a8a186c8420b0379edc (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.java51
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);
- }
-}