Package | Description |
---|---|
org.apache.flink.runtime.io.compression |
Modifier and Type | Method and Description |
---|---|
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 |
AirBlockCompressor.compress(byte[] src,
int srcOff,
int srcLen,
byte[] dst,
int dstOff) |
int |
Lz4BlockCompressor.compress(byte[] src,
int srcOff,
int srcLen,
byte[] 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 |
AirBlockCompressor.compress(ByteBuffer src,
int srcOff,
int srcLen,
ByteBuffer dst,
int dstOff) |
int |
Lz4BlockCompressor.compress(ByteBuffer src,
int srcOff,
int srcLen,
ByteBuffer dst,
int dstOff) |
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.