Module physical 

Physical plan compilation and execution.

Modules

budget

Resource accounting and lifecycle contracts used by bounded execution. Resource accounting and terminal-state contracts for bounded execution.

Structs

BatchOpenContext

Incremental batch source and stream contracts. Context supplied to a newly opened source. It shares one budget with the stream.

BudgetedMaterializedExecutor

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

ColumnarSegmentBatchPlan

Incremental batch source and stream contracts. Pre-decode ownership estimate for the next V08 columnar row group.

DataFrameStream

Incremental batch source and stream contracts. Incremental DataFrame result stream with one-way, repeatable terminal outcomes.

Executor

Physical plan executor. Executes PhysicalPlan trees and returns the resulting RecordBatch output.

SourceLimit

Physical plan compiler and plan node types. Source limitation visible before source I/O.

StreamBatch

Incremental batch source and stream contracts. A source-owned batch whose reservation remains held until consumer ownership transfer.

StreamingPhysicalPlan

Physical plan compiler and plan node types. A physical source and only the operators approved for batch-at-a-time execution.

Enums

PhysicalPlan

Physical plan compiler and plan node types. Physical execution plan produced from a LogicalPlan.

PlanSubject

Physical plan compiler and plan node types. Plan/source subject named by a streaming eligibility result.

ScanSource

Physical plan compiler and plan node types. Source for a physical scan operator.

StreamingEligibility

Physical plan compiler and plan node types. Eligibility outcome returned before opening a source.

StreamingOperator

Physical plan compiler and plan node types. Per-batch operator selected by the streaming compiler.

StreamingReason

Physical plan compiler and plan node types. Stable reason for a streaming eligibility outcome.

StreamingSource

Physical plan compiler and plan node types. Streaming source tree preserving concat input order and child operators.

Traits

BatchSource

Incremental batch source and stream contracts. Owned incremental reader for one logical source execution.

BatchSourceFactory

Incremental batch source and stream contracts. Re-consumable factory for a source; a factory must not perform source I/O until open.

ColumnarSegmentCursor

Incremental batch source and stream contracts. One owned V08 columnar segment cursor supplied by an adapter crate.

ColumnarSegmentProvider

Incremental batch source and stream contracts. Re-consumable V08 columnar source provider supplied by an adapter crate.

Functions

analyze_streaming

Physical plan compiler and plan node types. Analyze a plan before source I/O. Global nodes win over leaf-source results so callers never open a source merely to discover that a global operator cannot stream.

compile

Physical plan compiler and plan node types. Compile a LogicalPlan into a PhysicalPlan.

compile_streaming

Physical plan compiler and plan node types. Compile only a preflight-supported plan into a source plus batch-at-a-time operators.

record_batch_memory_size

Physical plan executor. Estimate Arrow-owned bytes for an already decoded batch.