alopex-dataframe 0.8.0

Polars-compatible DataFrame API for Alopex DB (v0.1)
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22

/// Resource accounting and lifecycle contracts used by bounded execution.
pub mod budget;
mod executor;
mod expr_eval;
mod operators;
mod plan;
mod streaming;

/// Physical plan executor.
pub use executor::{record_batch_memory_size, BudgetedMaterializedExecutor, Executor};
/// Physical plan compiler and plan node types.
pub use plan::{
    analyze_streaming, compile, compile_streaming, PhysicalPlan, PlanSubject, ScanSource,
    SourceLimit, StreamingEligibility, StreamingOperator, StreamingPhysicalPlan, StreamingReason,
    StreamingSource,
};
pub(crate) use streaming::open_streaming_plan;
/// Incremental batch source and stream contracts.
pub use streaming::{
    BatchOpenContext, BatchSource, BatchSourceFactory, ColumnarSegmentBatchPlan,
    ColumnarSegmentCursor, ColumnarSegmentProvider, DataFrameStream, StreamBatch,
};