Struct Expand

pub struct Expand<PlanRef> {
    pub column_subsets: Vec<Vec<usize>>,
    pub input: PlanRef,
}

Expand expand one row multiple times according to column_subsets and also keep original columns of input. It can be used to implement distinct aggregation and group set.

This is the schema of Expand: | expanded columns(i.e. some columns are set to null) | original columns of input | flag |.

Aggregates use expanded columns as their arguments and original columns for their filter. flag is used to distinguish between different subsets in column_subsets.

Fields

column_subsets: Vec<Vec<usize>>

input: PlanRef

Implementations

impl<PlanRef: GenericPlanRef> Expand<PlanRef>

pub fn output_len(&self) -> usize

fn flag_index(&self) -> usize

impl<PlanRef: GenericPlanRef> Expand<PlanRef>

fn column_subsets_pretty<'a>(&self) -> Pretty<'a>

pub fn i2o_col_mapping(&self) -> ColIndexMapping

pub fn o2i_col_mapping(&self) -> ColIndexMapping

pub fn decompose(self) -> (PlanRef, Vec<Vec<usize>>)

Trait Implementations

impl<PlanRef: Clone> Clone for Expand<PlanRef>

fn clone(&self) -> Expand<PlanRef>

Returns a copy of the value.

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

Performs copy-assignment from source.

impl<PlanRef: Debug> Debug for Expand<PlanRef>

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

Formats the value using the given formatter.

impl<PlanRef: GenericPlanRef> DistillUnit for Expand<PlanRef>

fn distill_with_name<'a>(&self, name: impl Into<Str<'a>>) -> XmlNode<'a>

impl<PlanRef: GenericPlanRef> GenericPlanNode for Expand<PlanRef>

fn schema(&self) -> Schema

fn stream_key(&self) -> Option<Vec<usize>>

fn ctx(&self) -> OptimizerContextRef

fn functional_dependency(&self) -> FunctionalDependencySet

impl<PlanRef: Hash> Hash for Expand<PlanRef>

fn hash<__H: Hasher>(&self, state: &mut __H)

Feeds this value into the given Hasher.

fn hash_slice<H>(data: &[Self], state: &mut H)

where H: Hasher, Self: Sized,

Feeds a slice of this type into the given Hasher.

impl<PlanRef: PartialEq> PartialEq for Expand<PlanRef>

fn eq(&self, other: &Expand<PlanRef>) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl<PlanRef: Eq> Eq for Expand<PlanRef>

impl<PlanRef> StructuralPartialEq for Expand<PlanRef>