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::*;

pub use fast_insert::*;

Modules

distributed 🔒

Distributed execution for batch query.

error 🔒

fast_insert 🔒

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