Struct BudgetedMaterializedExecutor 

pub struct BudgetedMaterializedExecutor { /* private fields */ }

Physical plan executor. Bounded materializing collector for callers that explicitly opt into a resource limit.

This collector only takes ownership of a batch after its retained output reservation has succeeded. Source readers and operators must reserve their own allocations before creating a batch; the streaming executor introduced later supplies that contract at those boundaries.

Implementations

impl BudgetedMaterializedExecutor

pub fn new(budget: ResourceBudget) -> Self

Construct a collector using the supplied shared resource budget.

pub fn collect_batches<I>(&self, batches: I) -> Result<DataFrame>

where I: IntoIterator<Item = Result<RecordBatch>>,

Materialize already-produced batches without exceeding the retained-output reservation.

The returned DataFrame transfers batch ownership to the caller, so this collector’s reservations are released before returning. An error drops all retained batches and their reservations.

pub fn collect_stream(&self, stream: &mut DataFrameStream) -> Result<DataFrame>

Drain an already-bounded stream while reserving each result batch before retaining it.

Source and operator allocations are owned by DataFrameStream; this collector adds only the materialized-result ownership needed for an explicit bounded collect. A reservation failure closes the stream so the source handle and all transient reservations are released.

pub fn budget(&self) -> &ResourceBudget

Return the shared budget used by this collector.

Trait Implementations

impl Clone for BudgetedMaterializedExecutor

fn clone(&self) -> BudgetedMaterializedExecutor

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for BudgetedMaterializedExecutor

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.