Struct dataflow_types::plan::join::delta_join::DeltaPathPlan [−][src]
pub struct DeltaPathPlan {
pub source_relation: usize,
pub source_key: Vec<MirScalarExpr>,
pub initial_closure: JoinClosure,
pub stage_plans: Vec<DeltaStagePlan>,
pub final_closure: Option<JoinClosure>,
}
Expand description
A delta query path is implemented by a sequences of stages,
Fields
source_relation: usize
The relation whose updates seed the dataflow path.
source_key: Vec<MirScalarExpr>
The key we expect the source relation to be arranged by.
initial_closure: JoinClosure
An initial closure to apply before any stages.
stage_plans: Vec<DeltaStagePlan>
A sequence of stages to apply one after the other.
final_closure: Option<JoinClosure>
A concluding closure to apply after the last stage.
Values of None
indicate the identity closure.
Trait Implementations
fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error> where
__D: Deserializer<'de>,
fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error> where
__D: Deserializer<'de>,
Deserialize this value from the given Serde deserializer. Read more
Auto Trait Implementations
impl RefUnwindSafe for DeltaPathPlan
impl Send for DeltaPathPlan
impl Sync for DeltaPathPlan
impl Unpin for DeltaPathPlan
impl UnwindSafe for DeltaPathPlan
Blanket Implementations
Mutably borrows from an owned value. Read more
Attaches the provided Subscriber
to this type, returning a
WithDispatch
wrapper. Read more
Attaches the current default Subscriber
to this type, returning a
WithDispatch
wrapper. Read more