Struct Shape 

pub struct Shape { /* private fields */ }

What a plan runs as.

Implementations

impl Shape

pub fn of(plan: &Plan) -> Self

Works out the shape of a plan.

pub fn pipelines(&self) -> usize

How many pipelines there are, which is at least one.

pub fn operators(&self) -> OperatorRef

How many operators the tree has, which is at least one and is more than the plan has nodes whenever the plan has a node with two inputs in it.

pub fn operator(&self, node: NodeRef) -> OperatorRef

The operator this node becomes.

Panics

If the node is not reachable from the plan’s root, which is a node the arena is still holding after a rewrite replaced it.

pub fn operator_of(&self, node: NodeRef) -> Option<OperatorRef>

The operator this node becomes, or none for a node the root does not reach.

The tolerant form of Shape::operator, for a caller walking the whole arena rather than the tree, which is what somebody filling one fact in per operator ends up doing.

pub fn gathered(&self, node: NodeRef) -> Option<OperatorRef>

The operator holding the side of this node that has to finish first, if it has two inputs.

Panics

The same as Shape::operator.

pub fn pipeline(&self, node: NodeRef) -> PipelineRef

The pipeline this node runs in.

For a sink that is the pipeline it ends rather than the one above it, so a sort is in the pipeline that feeds it and the operator that reads the sorted rows is in the one above.

Panics

The same as Shape::operator.

pub fn waits_for(&self, pipeline: PipelineRef) -> &[PipelineRef]

What this pipeline has to wait for, in ascending order.

Panics

If there is no such pipeline.

pub fn all(&self) -> impl Iterator<Item = PipelineRef>

Every pipeline, from the root’s outwards.

Trait Implementations

impl Clone for Shape

fn clone(&self) -> Shape

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for Shape

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

Formats the value using the given formatter.