本文整理了Java中com.github.luben.zstd.Zstd类的一些代码示例，展示了Zstd类的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。Zstd类的具体详情如下：
包路径：com.github.luben.zstd.Zstd
类名称：Zstd

Zstd介绍

暂无

代码示例

代码示例来源：origin: apache/pulsar

@Override
public ByteBuf encode(ByteBuf source) {
  int uncompressedLength = source.readableBytes();
  int maxLength = (int) Zstd.compressBound(uncompressedLength);
  ByteBuf target = PooledByteBufAllocator.DEFAULT.directBuffer(maxLength, maxLength);
  int compressedLength;
  if (source.hasMemoryAddress()) {
    compressedLength = (int) Zstd.compressUnsafe(target.memoryAddress(), maxLength,
        source.memoryAddress() + source.readerIndex(),
        uncompressedLength, ZSTD_COMPRESSION_LEVEL);
  } else {
    ByteBuffer sourceNio = source.nioBuffer(source.readerIndex(), source.readableBytes());
    ByteBuffer targetNio = target.nioBuffer(0, maxLength);
    compressedLength = Zstd.compress(targetNio, sourceNio, ZSTD_COMPRESSION_LEVEL);
  }
  target.writerIndex(compressedLength);
  return target;
}

代码示例来源：origin: apache/pulsar

@Override
  public ByteBuf decode(ByteBuf encoded, int uncompressedLength) throws IOException {
    ByteBuf uncompressed = PooledByteBufAllocator.DEFAULT.directBuffer(uncompressedLength, uncompressedLength);

    if (encoded.hasMemoryAddress()) {
      Zstd.decompressUnsafe(uncompressed.memoryAddress(), uncompressedLength,
          encoded.memoryAddress() + encoded.readerIndex(),
          encoded.readableBytes());
    } else {
      ByteBuffer uncompressedNio = uncompressed.nioBuffer(0, uncompressedLength);
      ByteBuffer encodedNio = encoded.nioBuffer(encoded.readerIndex(), encoded.readableBytes());

      Zstd.decompress(uncompressedNio, encodedNio);
    }

    uncompressed.writerIndex(uncompressedLength);
    return uncompressed;
  }
}

代码示例来源：origin: prestodb/presto

@Override
public int compress(byte[] input, int inputOffset, int inputLength, byte[] output, int outputOffset, int maxOutputLength)
{
  long size = Zstd.compressByteArray(output, outputOffset, maxOutputLength, input, inputOffset, inputLength, COMPRESSION_LEVEL);
  if (Zstd.isError(size)) {
    throw new RuntimeException(Zstd.getErrorName(size));
  }
  return toIntExact(size);
}

代码示例来源：origin: prestodb/presto

@Override
public int maxCompressedLength(int uncompressedSize)
{
  return toIntExact(Zstd.compressBound(uncompressedSize));
}

代码示例来源：origin: apache/ignite

/**
 * @param compactPage Compacted page.
 * @param compactSize Compacted page size.
 * @param compressLevel Compression level.
 * @return Compressed page.
 */
private ByteBuffer compressPageZstd(ByteBuffer compactPage, int compactSize, int compressLevel) {
  ByteBuffer compressedPage = compressBuf.get();
  copyPageHeader(compactPage, compressedPage, compactSize);
  Zstd.compress(compressedPage, compactPage, compressLevel);
  compactPage.flip();
  compressedPage.flip();
  return compressedPage;
}

代码示例来源：origin: apache/ignite

Zstd.decompress(dst, page);
dst.flip();

代码示例来源：origin: org.apache.carbondata/carbondata-core

@Override
public byte[] unCompressByte(byte[] compInput) {
 long decompressedSize = Zstd.decompressedSize(compInput);
 return Zstd.decompress(compInput, (int) decompressedSize);
}

代码示例来源：origin: org.apache.carbondata/carbondata-core

@Override
public long maxCompressedLength(long inputSize) {
 return Zstd.compressBound(inputSize);
}

代码示例来源：origin: org.apache.carbondata/carbondata-core

@Override
public byte[] compressByte(byte[] unCompInput) {
 return Zstd.compress(unCompInput, COMPRESS_LEVEL);
}

代码示例来源：origin: org.apache.carbondata/carbondata-core

@Override
public long rawUncompress(byte[] input, byte[] output) throws IOException {
 return Zstd.decompress(output, input);
}

代码示例来源：origin: io.prestosql/presto-orc

@Override
public int maxCompressedLength(int uncompressedSize)
{
  return toIntExact(Zstd.compressBound(uncompressedSize));
}

代码示例来源：origin: prestosql/presto

@Override
public int compress(byte[] input, int inputOffset, int inputLength, byte[] output, int outputOffset, int maxOutputLength)
{
  long size = Zstd.compressByteArray(output, outputOffset, maxOutputLength, input, inputOffset, inputLength, COMPRESSION_LEVEL);
  if (Zstd.isError(size)) {
    throw new RuntimeException(Zstd.getErrorName(size));
  }
  return toIntExact(size);
}

代码示例来源：origin: org.apache.carbondata/carbondata-core

@Override
public byte[] compressByte(byte[] unCompInput, int byteSize) {
 return Zstd.compress(unCompInput, COMPRESS_LEVEL);
}

代码示例来源：origin: airlift/aircompressor

@Override
public int decompress(byte[] input, int inputOffset, int inputLength, byte[] output, int outputOffset, int maxOutputLength)
    throws MalformedInputException
{
  byte[] compressed = Arrays.copyOfRange(input, inputOffset, inputLength);
  byte[] uncompressed = Zstd.decompress(compressed, maxOutputLength);
  System.arraycopy(uncompressed, 0, output, outputOffset, uncompressed.length);
  return uncompressed.length;
}

代码示例来源：origin: com.facebook.presto/presto-orc

@Override
public int maxCompressedLength(int uncompressedSize)
{
  return toIntExact(Zstd.compressBound(uncompressedSize));
}

代码示例来源：origin: com.facebook.presto/presto-orc

@Override
public int compress(byte[] input, int inputOffset, int inputLength, byte[] output, int outputOffset, int maxOutputLength)
{
  long size = Zstd.compressByteArray(output, outputOffset, maxOutputLength, input, inputOffset, inputLength, COMPRESSION_LEVEL);
  if (Zstd.isError(size)) {
    throw new RuntimeException(Zstd.getErrorName(size));
  }
  return toIntExact(size);
}

代码示例来源：origin: airlift/aircompressor

@Override
public int compress(byte[] input, int inputOffset, int inputLength, byte[] output, int outputOffset, int maxOutputLength)
{
  byte[] uncompressed = Arrays.copyOfRange(input, inputOffset, inputLength);
  byte[] compressed = Zstd.compress(uncompressed, level);
  System.arraycopy(compressed, 0, output, outputOffset, compressed.length);
  return compressed.length;
}

代码示例来源：origin: prestosql/presto

@Override
public int maxCompressedLength(int uncompressedSize)
{
  return toIntExact(Zstd.compressBound(uncompressedSize));
}

代码示例来源：origin: io.prestosql/presto-orc

@Override
public int compress(byte[] input, int inputOffset, int inputLength, byte[] output, int outputOffset, int maxOutputLength)
{
  long size = Zstd.compressByteArray(output, outputOffset, maxOutputLength, input, inputOffset, inputLength, COMPRESSION_LEVEL);
  if (Zstd.isError(size)) {
    throw new RuntimeException(Zstd.getErrorName(size));
  }
  return toIntExact(size);
}

代码示例来源：origin: airlift/aircompressor

@Override
public int maxCompressedLength(int uncompressedSize)
{
  return (int) Zstd.compressBound(uncompressedSize);
}