[FLINK-11858] Introduce block compressor/decompressor for batch table runtime

• Type: Improvement
• Status: Closed
• Priority: Major
• Resolution: Implemented
• Fix Version/s: 1.9.0
• Component/s: Runtime / Task
• Labels: pull-request-available
• Assignee: Kurt Young
• Reporter: Kurt Young
• Created: 08/Mar/19 04:05
• Updated: 11/Mar/19 13:21
• Resolved: 08/Mar/19 09:27

Description

Introduce block compressor/decompressor API to support future compression of the spilled data in batch table runtime. The compressor/decompressor works on block one at a time. A block is a piece of continuous data stored either in `byte[]` or `ByteBuffer`. We will first support lz4 compression algorithm.

Issue Links

• is a child of: FLINK-11490 Add an initial Blink SQL batch runtime
• links to: GitHub Pull Request #7941