Struct dataflow_types::plan::join::delta_join::DeltaStagePlan [−][src]
pub struct DeltaStagePlan {
pub lookup_relation: usize,
pub stream_key: Vec<MirScalarExpr>,
pub stream_thinning: Vec<usize>,
pub lookup_key: Vec<MirScalarExpr>,
pub closure: JoinClosure,
}
Expand description
A delta query stage performs a stream lookup into an arrangement.
Fields
lookup_relation: usize
The relation index into which we will look up.
stream_key: Vec<MirScalarExpr>
The key expressions to use for the streamed relation.
While this starts as a stream of the source relation, it evolves through multiple lookups and ceases to be the same thing, hence the different name.
stream_thinning: Vec<usize>
The thinning expression to apply on the value part of the stream
lookup_key: Vec<MirScalarExpr>
The key expressions to use for the lookup relation.
closure: JoinClosure
The closure to apply to the concatenation of columns of the stream and lookup relations.
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 DeltaStagePlan
impl Send for DeltaStagePlan
impl Sync for DeltaStagePlan
impl Unpin for DeltaStagePlan
impl UnwindSafe for DeltaStagePlan
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