MCPcopy Create free account

hub / github.com/datafusion-contrib/datafusion-dolomite / functions

Functions263 in github.com/datafusion-contrib/datafusion-dolomite

⨍ Functions 263◇ Types & classes 89
↓ 1 callersMethodjoin_type
(&self)
dolomite/src/operator/join.rs:25
↓ 1 callersMethodlogical_prop
(&self)
dolomite/src/heuristic/graph.rs:113
↓ 1 callersMethodmark_duplicated_group
Mark `src_group_id` and `dest_group_id` are duplicated.
dolomite/src/cascades/memo.rs:249
↓ 1 callersMethodmatches_without_children
(&self, pattern: &Pattern)
dolomite/src/cascades/memo.rs:772
↓ 1 callersMethodmerge_group
(&mut self, src: GroupId, dest: GroupId)
dolomite/src/cascades/memo.rs:202
↓ 1 callersMethodmerge_group_mappings
(&mut self, merge_group_mapping: &HashMap<GroupId, GroupId>)
dolomite/src/cascades/memo.rs:660
↓ 1 callersMethodnew_group
(&mut self)
dolomite/src/cascades/memo.rs:281
↓ 1 callersMethodnext_group_id
(&mut self)
dolomite/src/cascades/memo.rs:288
↓ 1 callersMethodnodes_iter
( &self, match_order: MatchOrder, )
dolomite/src/heuristic/graph.rs:35
↓ 1 callersMethodphysical_group_expr_ids
(&self)
dolomite/src/cascades/memo.rs:589
↓ 1 callersMethodphysical_props
(&self)
dolomite/src/plan/mod.rs:157
↓ 1 callersFunctionplan_node_to_df_logical_plan
(plan_node: &PlanNode)
datafusion-dolomite-integration/src/conversion/logical.rs:39
↓ 1 callersFunctionplan_node_to_df_physical_plan
( plan_node: &'a PlanNode, session_state: &'a SessionState, ctx: &'a OptimizerContext, )
datafusion-dolomite-integration/src/conversion/physical.rs:34
↓ 1 callersMethodreplace_opt_expression
Replace relational expression with optimizer rule result. # Return The return value indicates whether graph changed.
dolomite/src/heuristic/optimizer.rs:149
↓ 1 callersMethodreset_root
(&mut self, new_root: PlanNodeRef)
dolomite/src/plan/physical.rs:15
↓ 1 callersMethodrule_promise
(&self)
dolomite/src/rules/join.rs:66
↓ 1 callersMethodrun
(self)
datafusion-dolomite-integration/tests/utils/mod.rs:40
↓ 1 callersMethodrun_case
(&self, path: &P, test_case: TestCase)
datafusion-dolomite-integration/tests/utils/mod.rs:60
↓ 1 callersMethodscan
( &self, _ctx: &SessionState, projection: Option<&Vec<usize>>, _filters: &[Exp
datafusion-dolomite-integration/tests/utils/schema.rs:115
↓ 1 callersFunctionschedule
( context: &mut CascadesOptimizer, root: TaskImpl, )
dolomite/src/cascades/task.rs:58
↓ 1 callersMethodset_rule_applied
(&mut self, rule_id: RuleId)
dolomite/src/cascades/memo.rs:768
↓ 1 callersMethodstat
(&self)
dolomite/src/plan/mod.rs:153
↓ 1 callersFunctionto_df_logical
Convert dolomite logical plan to datafusion logical plan.
datafusion-dolomite-integration/src/conversion/logical.rs:28
↓ 1 callersFunctionto_df_physical
Convert dolomite physical plan to datafusion physical plan.
datafusion-dolomite-integration/src/conversion/physical.rs:23
↓ 1 callersMethodto_logical_plan
(&self, sql: &str)
datafusion-dolomite-integration/tests/utils/mod.rs:78
↓ 1 callersMethodto_plan
(&self)
dolomite/src/heuristic/graph.rs:71
↓ 1 callersMethodtop_down_node_iters
Return node ids in bottom up order.
dolomite/src/heuristic/graph.rs:59
↓ 1 callersMethodtry_optimize
( &self, df_plan: &LogicalPlan, _optimizer_config: &dyn OptimizerConfig, )
datafusion-dolomite-integration/src/rule.rs:26
↓ 1 callersFunctiontuple_err
Copied from data fusion.
datafusion-dolomite-integration/src/conversion/physical.rs:132
↓ 1 callersMethodupdate_winner_input
( &mut self, output_prop: &PhysicalPropertySet, input_props: &[PhysicalPropertySet],
dolomite/src/cascades/memo.rs:805
↓ 1 callersMethodwith_logical_prop
(mut self, logical_prop: Option<LogicalProperty>)
dolomite/src/plan/mod.rs:188
↓ 1 callersMethodwith_physical_props
( mut self, physical_props: Option<PhysicalPropertySet>, )
dolomite/src/plan/mod.rs:198
↓ 1 callersMethodwith_statistics
(mut self, stat: Option<Statistics>)
dolomite/src/plan/mod.rs:193
Functionany
(_: &Operator)
dolomite/src/rules/pattern.rs:79
Methodappend_enforcers
When `input_prop` doesn't meet requirements of `required_prop`, try to append enforcer physical operators to ensure requirement.s
dolomite/src/properties/physical.rs:19
Methodapply
( &self, input: OptExpression<O>, _ctx: &O, result: &mut RuleResult<O>, )
dolomite/src/rules/table_scan.rs:31
Methodas_any
(&self)
datafusion-dolomite-integration/tests/utils/schema.rs:72
Methodbegin
( self, node: K, )
dolomite/src/utils.rs:9
Methodbuild
Consume current plan, but not rest state, e.g. plan node id. This is useful for building multi child plan, e.g. join.
dolomite/src/plan/logical.rs:92
Methodbuild
(self)
dolomite/src/plan/physical.rs:55
Functionbuild_plan_with_multi_child
()
dolomite/src/cascades/memo.rs:926
Methodchildren
(&self)
dolomite/src/plan/explain.rs:15
Methodcontext
(&self)
dolomite/src/heuristic/optimizer.rs:38
Methodcost
(&self, expr: &O::Expr)
dolomite/src/cost/trivial.rs:13
Functioncreate_table_source
(fields: Vec<Field>)
datafusion-dolomite-integration/tests/utils/schema.rs:36
Methoddefault
()
dolomite/src/optimizer.rs:17
Methoddefault
()
dolomite/src/plan/mod.rs:24
Methoddefault
()
dolomite/src/plan/logical.rs:14
Methoddefault
()
dolomite/src/rules/mod.rs:80
Methodderive_logical_prop
( &self, handle: O::ExprHandle, optimizer: &O, )
dolomite/src/operator/filter.rs:39
Methodderive_logical_prop
( &self, handle: O::ExprHandle, optimizer: &O, )
dolomite/src/operator/limit.rs:23
Methodderive_logical_prop
( &self, _handle: O::ExprHandle, optimizer: &O, )
dolomite/src/operator/table_scan.rs:56
Methodderive_logical_prop
( &self, handle: O::ExprHandle, optimizer: &O, )
dolomite/src/operator/projection.rs:42
Methodderive_logical_prop
( &self, handle: O::ExprHandle, optimizer: &O, )
dolomite/src/operator/join.rs:50
Methodderive_logical_property
(&self)
dolomite/src/cascades/memo.rs:785
Methodderive_properties
( &self, _context: DerivePropContext<O>, )
dolomite/src/operator/filter.rs:30
Methodderive_properties
( &self, _context: DerivePropContext<O>, )
dolomite/src/operator/table_scan.rs:44
Methodderive_properties
( &self, _context: DerivePropContext<O>, )
dolomite/src/operator/projection.rs:33
Methodderive_statistics
(&self)
dolomite/src/cascades/memo.rs:781
Methoddisplay
(&self, fmt: &mut Formatter)
dolomite/src/operator/filter.rs:60
Methoddisplay
(&self, f: &mut Formatter<'_>)
dolomite/src/operator/limit.rs:35
Methoddisplay
(&self, f: &mut Formatter<'_>)
dolomite/src/operator/table_scan.rs:78
Methoddisplay
(&self, f: &mut Formatter)
dolomite/src/operator/projection.rs:64
Methoddone
()
dolomite/src/cascades/task.rs:42
Methoddone_with_deps
(deps: Vec<TaskImpl>)
dolomite/src/cascades/task.rs:48
Methodeq
(&self, other: &Self)
dolomite/src/plan/mod.rs:56
Methodeq
(&self, other: &Self)
dolomite/src/rules/opt_expr.rs:29
Methodestimate_cost
Estimate cost of current operator without accumulating children's cost.
dolomite/src/cost/mod.rs:32
Methodexpr
(&self)
dolomite/src/operator/projection.rs:27
Methodfind_best_plan
(mut self)
dolomite/src/heuristic/optimizer.rs:50
Methodfmt
(&self, f: &mut Formatter<'_>)
dolomite/src/operator/mod.rs:66
Methodfmt
(&self, f: &mut Formatter<'_>)
dolomite/src/operator/logical.rs:21
Methodfmt
(&self, f: &mut Formatter<'_>)
dolomite/src/operator/physical.rs:44
Methodfmt
(&self, f: &mut Formatter<'_>)
dolomite/src/rules/opt_expr.rs:44
Methodfmt
(&self, f: &mut Formatter<'_>)
dolomite/src/rules/mod.rs:160
Methodfmt
(&self, f: &mut Formatter<'_>)
dolomite/src/cascades/memo.rs:397
Methodfrom
(c: f64)
dolomite/src/cost/mod.rs:19
Methodfrom
(t: Operator)
dolomite/src/rules/opt_expr.rs:54
Methodfrom
(t: (OperatorMatcher, Vec<Pattern>))
dolomite/src/rules/pattern.rs:35
Methodfrom
(plan: Plan)
dolomite/src/cascades/memo.rs:332
Methodfrom
(t: &'a PlanNode)
dolomite/src/heuristic/graph.rs:101
Methodget_aggregate_meta
(&self, _name: &str)
datafusion-dolomite-integration/tests/utils/schema.rs:57
Methodget_function_meta
(&self, _name: &str)
datafusion-dolomite-integration/tests/utils/schema.rs:53
Methodget_group
(&self, group_id: GroupId)
dolomite/src/cascades/memo.rs:303
Methodget_table_provider
(&self, name: TableReference)
datafusion-dolomite-integration/tests/utils/schema.rs:43
Methodget_variable_type
(&self, _variable_names: &[String])
datafusion-dolomite-integration/tests/utils/schema.rs:61
Methodgroup_at
(&self, group_handle: HepNodeId)
dolomite/src/heuristic/optimizer.rs:42
Methodindex
(&self, index: usize)
dolomite/src/rules/opt_expr.rs:191
Methodindex
(&self, index: GroupId)
dolomite/src/cascades/memo.rs:371
Methodindex_mut
(&mut self, index: GroupId)
dolomite/src/cascades/memo.rs:377
Methodinputs
(&self)
dolomite/src/rules/opt_expr.rs:129
Methodinputs_len
(&self, _opt: &CascadesOptimizer)
dolomite/src/cascades/memo.rs:742
Methodis_physical
(&self)
dolomite/src/cascades/memo.rs:797
Methodlimit
(&self)
dolomite/src/operator/limit.rs:17
Methodlimit
(&self)
dolomite/src/operator/table_scan.rs:34
Methodlogical_prop
(&self)
dolomite/src/cascades/memo.rs:563
Methodmatches
(op: &Operator)
dolomite/src/rules/join.rs:36
Methodmerge_duplicate_groups
Process `duplicate_groups` and merge them.
dolomite/src/cascades/memo.rs:160
Methodname
(&self)
datafusion-dolomite-integration/src/rule.rs:53
Methodnew
(tables: HashMap<String, Arc<MyTable>>)
datafusion-dolomite-integration/tests/utils/schema.rs:28
← previousnext →101–200 of 263, ranked by callers