datafusion-distributed 2.0.0

mod remote_work_unit_feed;
mod work_unit;
#[allow(clippy::module_inception)]
mod work_unit_feed;
mod work_unit_feed_provider;
mod work_unit_feed_registry;

pub(crate) use remote_work_unit_feed::{
    RemoteWorkUnitFeedRegistry, build_work_unit_batch_msg, set_work_unit_received_time,
    set_work_unit_send_time,
};
pub(crate) use work_unit_feed_registry::{WorkUnitFeedRegistry, set_distributed_work_unit_feed};

pub use work_unit::WorkUnit;
pub use work_unit_feed::{WorkUnitFeed, WorkUnitFeedProto};
pub use work_unit_feed_provider::{DistributedWorkUnitFeedContext, WorkUnitFeedProvider};