Skip to main content

alopex_dataframe/physical/
mod.rs

1/// Resource accounting and lifecycle contracts used by bounded execution.
2pub mod budget;
3mod executor;
4mod expr_eval;
5mod operators;
6mod plan;
7mod streaming;
8
9/// Physical plan executor.
10pub use executor::{record_batch_memory_size, BudgetedMaterializedExecutor, Executor};
11/// Physical plan compiler and plan node types.
12pub use plan::{
13    analyze_streaming, compile, compile_streaming, PhysicalPlan, PlanSubject, ScanSource,
14    SourceLimit, StreamingEligibility, StreamingOperator, StreamingPhysicalPlan, StreamingReason,
15    StreamingSource,
16};
17pub(crate) use streaming::open_streaming_plan;
18/// Incremental batch source and stream contracts.
19pub use streaming::{
20    BatchOpenContext, BatchSource, BatchSourceFactory, ColumnarSegmentBatchPlan,
21    ColumnarSegmentCursor, ColumnarSegmentProvider, DataFrameStream, StreamBatch,
22};