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