Module property

Define all property of plan tree node, which actually represent property of the node’s result.

We have physical property Order and Distribution which is on batch or stream operator, also, we have logical property which all PlanNode has.

We have not give any common abstract trait for the property yet. They are not so much and we don’t need get a common behavior now. we can treat them as different traits of the PlanNode now and refactor them when our optimizer need more (such as an optimizer based on the Volcano/Cascades model).

Modules

cardinality 🔒

distribution 🔒

“A -> B” represent A satisfies B x only as a required property x can used as both required x and provided property x ┌───┐ x┌──────┐ │Any◄─────────────────┤single│ └─▲─┘ x└──────┘ │ x │ x │ x ┌───┴────┐ x┌──────────┐ │AnyShard◄──────────────┤SomeShard │ └───▲────┘ x└──────────┘ │ x ┌───┴───────────┐ x┌──────────────┐ ┌──────────────┐ │ShardByKey(a,b)◄───┬───┤HashShard(a,b)│ │HashShard(b,a)│ └───▲──▲────────┘ │ x└──────────────┘ └┬─────────────┘ │ │ │ x │ │ │ └─────────────────────┘ │ │ x │ ┌┴────────────┐ x┌────────────┐ │ │ShardByKey(a)◄───┤HashShard(a)│ │ └─────────────┘ x└────────────┘ │ x ┌┴────────────┐ x┌────────────┐ │ShardByKey(b)◄──────┤HashShard(b)│ └─────────────┘ x└────────────┘ x x

func_dep 🔒

monotonicity 🔒

monotonicity_variants

order 🔒

watermark_columns 🔒

Structs

Cardinality

The cardinality of the output rows of a plan node. Bounds are inclusive.

DistributionDisplay

FunctionalDependency

FunctionalDependency represent a dependency of from –> to.

FunctionalDependencySet

FunctionalDependencySet contains the functional dependencies.

MonotonicityMap

A map from column index to its monotonicity.

Order

OrderDisplay

WatermarkColumns

Represents the output watermark columns of a plan node.

Enums

Distribution

the distribution property provided by a operator.

Hi

The upper bound of the Cardinality.

Monotonicity

Represents the monotonicity of a column.

MonotonicityDerivation

Represents the derivation of the monotonicity of a column. This enum aims to unify the “non-decreasing analysis” and watermark derivation.

RequiredDist

the distribution property requirement.

Functions

analyze_monotonicity

Analyze the monotonicity of an expression.

Type Aliases

WatermarkGroupId