Modules§
- analyzer 🔒
- commutativity 🔒
- dyn_
filter_ 🔒bridge - filter_
id 🔒 - merge_
scan 🔒 - merge_
sort 🔒 - Merge sort logical plan for distributed query execution, roughly corresponding to the
SortPreservingMergeExecoperator in datafusion - planner 🔒
- [ExtensionPlanner] implementation for distributed planner
- predicate_
extractor 🔒 - Predicate extraction for partition pruning.
- region_
pruner 🔒 ConstraintPrunerprunes partition info based on given expressions.- remote_
dyn_ 🔒filter_ receiver - remote_
dyn_ 🔒filter_ registry
Structs§
- Constraint
Pruner - Dist
Extension Planner - Dist
Planner Analyzer - Dist
Planner Options - DynFilter
Entry - A registered query-local producer filter and its region subscribers.
- DynFilter
Registry Manager - Query-engine manager for query-scoped remote dynamic filter registries.
- Filter
Fingerprint - Filter
Id - Merge
Scan Exec - Merge
Scan Logical Plan - Merge
Sort Extension Planner - Planner for convert merge sort logical plan to physical plan
- Parse
Filter IdError - Predicate
Extractor - Extracts a list of
PartitionExprfrom given [LogicalPlan] - Query
DynFilter Registry - Query-scoped registry that owns all remote dynamic filters for one query.
- Remote
DynFilter Producer Id - Query-local identity for one remote dynamic filter producer.
- Remote
DynFilter Receiver Extension Planner - Remote
DynFilter Receiver Injector - Injects a logical remote dynamic filter receiver into a query plan.
- Remote
DynFilter Receiver Logical Plan - A logical marker that is converted to a [
FilterExec] carrying remote dynamic filters. - Remote
DynFilter Registry Lease - Stream-scoped lease that keeps a query registry alive.
- Subscriber
- Region subscribed to a remote dynamic filter.
Enums§
- Entry
Registration - Result of registering a remote dynamic filter entry.
- Subscriber
Registration - Result of registering a subscriber under an existing filter entry.