Module convert

Source

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.