risingwave_batch::executor

Module hash_agg

source

Structs§

  • 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 implements the hash aggregate algorithm.

Type Aliases§