pub mod cluster;
pub mod config;
mod error;
pub mod event;
pub mod executor;
pub mod heartbeat;
pub mod network;
pub mod physical_plan;
pub mod planner;
pub mod runtime;
pub mod scheduler;
pub mod util;
use std::pin::Pin;
pub use error::{DistError, DistResult};
use arrow::array::RecordBatch;
use futures::Stream;
pub type RecordBatchStream = Pin<Box<dyn Stream<Item = DistResult<RecordBatch>> + Send>>;