Module hash_agg

Source

Structs§

AggSpillManager
AggSpillManager is used to manage how to write spill data file and read them back. The spill data first need to be partitioned. Each partition contains 2 files: agg_state_file and input_chunks_file. The spill file consume a data chunk and serialize the chunk into a protobuf bytes. Finally, spill file content will look like the below. The file write pattern is append-only and the read pattern is sequential scan. This can maximize the disk IO performance.
HashAggExecutor
HashAggExecutor implements the hash aggregate algorithm.
HashAggExecutorBuilder

Type Aliases§

AggHashMap 🔒