datafusion-distributed 1.0.0

pub(crate) mod generated;
mod impl_execute_task;
mod impl_set_plan;
mod session_builder;
mod single_write_multi_read;
mod spawn_select_all;
#[cfg(any(test, feature = "integration"))]
pub(crate) mod test_utils;
mod worker_connection_pool;
mod worker_service;

pub(crate) use single_write_multi_read::SingleWriteMultiRead;
pub(crate) use worker_connection_pool::WorkerConnectionPool;

pub use session_builder::{
    DefaultSessionBuilder, MappedWorkerSessionBuilder, MappedWorkerSessionBuilderExt,
    WorkerQueryContext, WorkerSessionBuilder,
};
pub use worker_service::Worker;

pub use impl_set_plan::TaskData;