Skip to main content

plan_region_batches

Function plan_region_batches 

Source
pub(crate) fn plan_region_batches(
    combined_batch: RecordBatch,
    physical_table_id: TableId,
    partition_rule: &dyn PartitionRule,
) -> Result<Vec<PlannedRegionBatch>>
Expand description

Partitions a physical flush while retaining columns needed for rerouting.