datafusion_dist/lib.rs
1pub mod cluster;
2pub mod config;
3mod error;
4pub mod event;
5pub mod heartbeat;
6pub mod network;
7pub mod physical_plan;
8pub mod planner;
9pub mod runtime;
10pub mod schedule;
11pub mod util;
12
13use std::pin::Pin;
14
15pub use error::{DistError, DistResult};
16
17use datafusion::arrow::array::RecordBatch;
18use futures::Stream;
19
20pub type RecordBatchStream = Pin<Box<dyn Stream<Item = DistResult<RecordBatch>> + Send>>;