Module convert

Structs

RewriteStreamContext

ToStreamContext

Traits

ToBatch

ToBatch allows to convert a logical plan node to batch physical node with an optional required order.

ToDistributedBatch

ToDistributedBatch allows to convert a batch physical plan to distributed batch plan, by insert exchange node, with an optional required order and distributed.

ToLocalBatch

Converts a batch physical plan to local plan for local execution.

ToStream

ToStream converts a logical plan node to streaming physical node with an optional required distribution.

Functions

stream_enforce_eowc_requirement

try_enforce_locality_requirement

Try to enforce the locality requirement on the given columns. If a better plan can be found, return the better plan. If no better plan can be found, and locality backfill is enabled, wrap the plan with LogicalLocalityProvider. Otherwise, return the plan as is.