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

ZstdDecompressor.decompress介绍

暂无

代码示例

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

@Override
public int decompress(byte[] input, int offset, int length, OutputBuffer output)
    throws OrcCorruptionException
{
  try {
    long uncompressedLength = ZstdDecompressor.getDecompressedSize(input, offset, length);
    if (uncompressedLength > maxBufferSize) {
      throw new OrcCorruptionException(orcDataSourceId, "Zstd requires buffer (%s) larger than max size (%s)", uncompressedLength, maxBufferSize);
    }
    byte[] buffer = output.initialize(toIntExact(uncompressedLength));
    return decompressor.decompress(input, offset, length, buffer, 0, buffer.length);
  }
  catch (MalformedInputException e) {
    throw new OrcCorruptionException(e, orcDataSourceId, "Invalid compressed stream");
  }
}

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

@Override
public int decompress(byte[] input, int offset, int length, OutputBuffer output)
    throws OrcCorruptionException
{
  try {
    long uncompressedLength = ZstdDecompressor.getDecompressedSize(input, offset, length);
    if (uncompressedLength > maxBufferSize) {
      throw new OrcCorruptionException(orcDataSourceId, "Zstd requires buffer (%s) larger than max size (%s)", uncompressedLength, maxBufferSize);
    }
    byte[] buffer = output.initialize(toIntExact(uncompressedLength));
    return decompressor.decompress(input, offset, length, buffer, 0, buffer.length);
  }
  catch (MalformedInputException e) {
    throw new OrcCorruptionException(e, orcDataSourceId, "Invalid compressed stream");
  }
}

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

@Override
public int decompress(byte[] input, int offset, int length, OutputBuffer output)
    throws OrcCorruptionException
{
  try {
    long uncompressedLength = ZstdDecompressor.getDecompressedSize(input, offset, length);
    if (uncompressedLength > maxBufferSize) {
      throw new OrcCorruptionException(orcDataSourceId, "Zstd requires buffer (%s) larger than max size (%s)", uncompressedLength, maxBufferSize);
    }
    byte[] buffer = output.initialize(toIntExact(uncompressedLength));
    return decompressor.decompress(input, offset, length, buffer, 0, buffer.length);
  }
  catch (MalformedInputException e) {
    throw new OrcCorruptionException(e, orcDataSourceId, "Invalid compressed stream");
  }
}

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

@Override
public int decompress(byte[] input, int offset, int length, OutputBuffer output)
    throws OrcCorruptionException
{
  try {
    long uncompressedLength = ZstdDecompressor.getDecompressedSize(input, offset, length);
    if (uncompressedLength > maxBufferSize) {
      throw new OrcCorruptionException(orcDataSourceId, "Zstd requires buffer (%s) larger than max size (%s)", uncompressedLength, maxBufferSize);
    }
    byte[] buffer = output.initialize(toIntExact(uncompressedLength));
    return decompressor.decompress(input, offset, length, buffer, 0, buffer.length);
  }
  catch (MalformedInputException e) {
    throw new OrcCorruptionException(e, orcDataSourceId, "Invalid compressed stream");
  }
}