Package | Description |
---|---|
org.apache.flink.runtime.io.compression |
Modifier and Type | Method and Description |
---|---|
int |
Lz4BlockCompressor.compress(byte[] src,
int srcOff,
int srcLen,
byte[] dst,
int dstOff) |
int |
BlockCompressor.compress(byte[] src,
int srcOff,
int srcLen,
byte[] dst,
int dstOff)
Compress data read from src, and write the compressed data to dst.
|
int |
Lz4BlockCompressor.compress(ByteBuffer src,
int srcOff,
int srcLen,
ByteBuffer dst,
int dstOff) |
int |
BlockCompressor.compress(ByteBuffer src,
int srcOff,
int srcLen,
ByteBuffer dst,
int dstOff)
Compress source data read from (
Buffer.position() + srcOff ),
and write the compressed data to dst. |
int |
Lz4BlockDecompressor.decompress(byte[] src,
int srcOff,
int srcLen,
byte[] dst,
int dstOff) |
int |
BlockDecompressor.decompress(byte[] src,
int srcOff,
int srcLen,
byte[] dst,
int dstOff)
Decompress source data read from src and write the decompressed data to dst.
|
int |
BlockDecompressor.decompress(ByteBuffer src,
int srcOff,
int srcLen,
ByteBuffer dst,
int dstOff)
Decompress source data read from (
Buffer.position() + srcOff ),
and write the decompressed data to dst. |
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.