Module scheduler

Fragment and schedule batch queries.

Re-exports

• pub use plan_fragmenter::BatchPlanFragmenter;
• pub use self::error::SchedulerError;
• pub use distributed::*;
• pub use snapshot::*;
• pub use local::*;

Modules

• distributed 🔒
  Distributed execution for batch query.
• error 🔒
• local 🔒
  Local execution for batch query.
• plan_fragmenter
• snapshot 🔒
• streaming_manager
• task_context 🔒

Structs

• ExecutionContext
  Context for mpp query execution.

Type Aliases

• ExecutionContextRef
• SchedulerResult

Trait Aliases

• DataChunkStream