Struct dataflow_types::plan::join::linear_join::LinearStagePlan

pub struct LinearStagePlan {
    pub lookup_relation: usize,
    pub stream_key: Vec<MirScalarExpr>,
    pub stream_thinning: Vec<usize>,
    pub lookup_key: Vec<MirScalarExpr>,
    pub closure: JoinClosure,
}

A plan for the execution of one stage of a linear join.

Each stage is a binary join between the current accumulated join results, and a new collection. The former is referred to as the “stream” and the latter the “lookup”.

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 use to remove redundant value columns when arranging 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

impl Clone for LinearStagePlan

fn clone(&self) -> LinearStagePlan

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for LinearStagePlan

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for LinearStagePlan

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error> where
    __D: Deserializer<'de>, 

Deserialize this value from the given Serde deserializer.

impl Serialize for LinearStagePlan

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error> where
    __S: Serializer, 

Serialize this value into the given Serde serializer.