org.apache.commons.compress.compressors.zstandard.ZstdCompressorOutputStream.<init>()方法的使用及代码示例

x33g5p2x  于2022-02-05 转载在 其他  
字(1.7k)|赞(0)|评价(0)|浏览(112)

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

ZstdCompressorOutputStream.<init>介绍

[英]Wraps the given stream into a zstd-jni ZstdOutputStream using the default values for level, closeFrameOnFlush and useChecksum.
[中]使用level、closeFrameOnFlush和useChecksum的默认值将给定流包装到zstd jni zstOutputStream中。

代码示例

代码示例来源:origin: apache/avro

@Override
public ByteBuffer compress(ByteBuffer data) throws IOException {
  ByteArrayOutputStream baos = getOutputBuffer(data.remaining());
  try (OutputStream outputStream = new ZstdCompressorOutputStream(baos)) {
    outputStream.write(data.array(), computeOffset(data), data.remaining());
  }
  return ByteBuffer.wrap(baos.toByteArray());
}

代码示例来源:origin: apache/incubator-druid

@Test
public void testDecompressZstd() throws IOException
{
 final File tmpDir = temporaryFolder.newFolder("testDecompressZstd");
 final File zstdFile = new File(tmpDir, testFile.getName() + ".zst");
 Assert.assertFalse(zstdFile.exists());
 try (final OutputStream out = new ZstdCompressorOutputStream(new FileOutputStream(zstdFile))) {
  ByteStreams.copy(new FileInputStream(testFile), out);
 }
 try (final InputStream inputStream = CompressionUtils.decompress(new FileInputStream(zstdFile), zstdFile.getName())) {
  assertGoodDataStream(inputStream);
 }
}

代码示例来源:origin: org.apache.commons/commons-compress

return new ZstdCompressorOutputStream(out);

代码示例来源:origin: com.impetus.fabric/fabric-jdbc-driver-shaded

return new ZstdCompressorOutputStream(out);

相关文章

ZstdCompressorOutputStream类方法