Uses of Class
org.apache.flink.runtime.io.compression.InsufficientBufferException

Packages that use InsufficientBufferException

Package	Description
org.apache.flink.runtime.io.compression

Uses of InsufficientBufferException in org.apache.flink.runtime.io.compression

Methods in org.apache.flink.runtime.io.compression that throw InsufficientBufferException

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.