本文整理了Java中org.apache.commons.compress.compressors.zstandard.ZstdCompressorInputStream
类的一些代码示例,展示了ZstdCompressorInputStream
类的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。ZstdCompressorInputStream
类的具体详情如下:
包路径:org.apache.commons.compress.compressors.zstandard.ZstdCompressorInputStream
类名称:ZstdCompressorInputStream
[英]CompressorInputStream implementation to decode Zstandard encoded stream. Library relies on Zstandard JNI
[中]CompressorInputStream实现对标准编码流进行解码。库依赖于Zstandard JNI
代码示例来源:origin: apache/avro
@Override
public ByteBuffer decompress(ByteBuffer compressedData) throws IOException {
ByteArrayOutputStream baos = getOutputBuffer(compressedData.remaining());
InputStream bytesIn = new ByteArrayInputStream(
compressedData.array(),
computeOffset(compressedData),
compressedData.remaining());
try (InputStream ios = new ZstdCompressorInputStream(bytesIn)) {
IOUtils.copy(ios, baos);
}
return ByteBuffer.wrap(baos.toByteArray());
}
代码示例来源:origin: org.apache.commons/commons-compress
@Override
public int read(final byte[] buf, final int off, final int len) throws IOException {
final int ret = decIS.read(buf, off, len);
count(ret);
return ret;
}
代码示例来源:origin: apache/incubator-druid
return new FramedSnappyCompressorInputStream(in);
} else if (fileName.endsWith(ZSTD_SUFFIX)) {
return new ZstdCompressorInputStream(in);
} else if (fileName.endsWith(ZIP_SUFFIX)) {
代码示例来源:origin: org.apache.commons/commons-compress
@Override
public int read() throws IOException {
final int ret = decIS.read();
count(ret == -1 ? 0 : 1);
return ret;
}
代码示例来源:origin: org.apache.commons/commons-compress
throw new CompressorException("Zstandard compression is not available." + YOU_NEED_ZSTD_JNI);
return new ZstdCompressorInputStream(in);
代码示例来源:origin: com.impetus.fabric/fabric-jdbc-driver-shaded
@Override
public int read(final byte[] buf, final int off, final int len) throws IOException {
final int ret = decIS.read(buf, off, len);
count(ret);
return ret;
}
代码示例来源:origin: org.apache.druid/java-util
return new FramedSnappyCompressorInputStream(in);
} else if (fileName.endsWith(ZSTD_SUFFIX)) {
return new ZstdCompressorInputStream(in);
} else if (fileName.endsWith(ZIP_SUFFIX)) {
代码示例来源:origin: com.impetus.fabric/fabric-jdbc-driver-shaded
@Override
public int read() throws IOException {
final int ret = decIS.read();
count(ret == -1 ? 0 : 1);
return ret;
}
代码示例来源:origin: com.impetus.fabric/fabric-jdbc-driver-shaded
throw new CompressorException("Zstandard compression is not available." + YOU_NEED_ZSTD_JNI);
return new ZstdCompressorInputStream(in);
内容来源于网络,如有侵权,请联系作者删除!