Struct SpillContext 

pub struct SpillContext { /* private fields */ }

쿼리 단위 Spill 컨텍스트.

HashAggregateOperator 등 메모리 집약 연산자에 주입되어, 메모리 사용량이 budget_bytes를 초과하면 RecordBatch를 임시 디스크로 내보냅니다.

Implementations

impl SpillContext

pub fn new() -> DbxResult<Self>

기본 메모리 예산(128MB)으로 SpillContext 생성.

pub fn with_budget(budget_bytes: usize) -> DbxResult<Self>

지정된 메모리 예산(바이트)으로 SpillContext 생성.

pub fn track(&mut self, bytes: usize)

바이트 단위 메모리 사용량을 등록합니다. RecordBatch의 크기는 estimate_batch_bytes로 추정합니다.

pub fn should_spill(&self) -> bool

현재 메모리 사용량이 예산을 초과했는지 확인합니다.

pub fn reset_tracking(&mut self)

메모리 사용량 추적을 초기화합니다 (Spill 후 재시작).

pub fn spill_batches(&mut self, batches: &[RecordBatch]) -> DbxResult<PathBuf>

RecordBatch 목록을 Arrow IPC 포맷으로 임시 파일에 씁니다.

반환

Spill된 파일의 경로를 반환합니다.

pub fn spill_partition_batch( &mut self, side: &str, part_idx: usize, batch: RecordBatch, ) -> DbxResult<PathBuf>

특정 파티션에 속한 RecordBatch를 Spill 합니다 (Grace Hash Join 용). 파일명 규칙: {side}_{part_idx}_{count}.ipc

pub fn reload_batches(path: &PathBuf) -> DbxResult<Vec<RecordBatch>>

Spill 파일에서 RecordBatch 목록을 읽어옵니다.

읽기 완료 후 파일은 삭제되지 않습니다 (TempDir drop 시 일괄 삭제).

pub fn estimate_batch_bytes(batch: &RecordBatch) -> usize

RecordBatch의 메모리 사용량을 추정합니다 (컬럼 버퍼 합산).