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
↓ 59 callersMethodclone
(&self)
dolomite/src/rules/opt_expr.rs:19
↓ 24 callersMethodclone
(&self)
dolomite/src/cascades/binding.rs:26
↓ 22 callersMethodinto_iter
(self)
dolomite/src/cascades/binding.rs:50
↓ 21 callersMethodlimit
(&mut self, limit: usize)
dolomite/src/plan/logical.rs:62
↓ 20 callersMethodbuild
(self)
dolomite/src/plan/mod.rs:206
↓ 15 callersMethodscan
( &mut self, limit: Option<usize>, table_name: S, )
dolomite/src/plan/logical.rs:33
↓ 13 callersMethodlogical_group_expr_ids
(&self)
dolomite/src/cascades/memo.rs:593
↓ 10 callersMethodroot
(&self)
dolomite/src/plan/mod.rs:109
↓ 9 callersMethodget_operator
(&'a self, optimizer: &'a O)
dolomite/src/rules/opt_expr.rs:137
↓ 9 callersMethodid
(&self)
dolomite/src/plan/mod.rs:141
↓ 8 callersMethodlogical_prop
(&self)
dolomite/src/plan/mod.rs:149
↓ 7 callersMethodinput_at
(&self, idx: usize, _opt: &CascadesOptimizer)
dolomite/src/cascades/memo.rs:746
↓ 7 callersMethodinputs
(&self)
dolomite/src/cascades/memo.rs:801
↓ 7 callersMethodnext
(self)
dolomite/src/heuristic/binding.rs:24
↓ 7 callersMethodprojection
(&mut self, exprs: I)
dolomite/src/plan/logical.rs:51
↓ 6 callersMethodadd
(&mut self, new_expr: OptExpression<O>)
dolomite/src/rules/mod.rs:90
↓ 6 callersMethodend
(self)
dolomite/src/utils.rs:69
↓ 6 callersMethodexpr_at
(&self, expr_handle: GroupExprId)
dolomite/src/cascades/optimizer.rs:35
↓ 6 callersMethodjoin
( &mut self, join_type: JoinType, condition: Expr, right: PlanNodeRef, )
dolomite/src/plan/logical.rs:73
↓ 6 callersMethodschema
(&self)
dolomite/src/properties/logical.rs:17
↓ 5 callersMethodbuild
(self)
datafusion-dolomite-integration/tests/utils/hep_optimizer.rs:53
↓ 5 callersMethodgroup_at
(&self, group_handle: GroupId)
dolomite/src/cascades/optimizer.rs:31
↓ 5 callersMethodinputs
(&self)
dolomite/src/plan/mod.rs:145
↓ 5 callersMethodnode
(&self)
dolomite/src/rules/opt_expr.rs:133
↓ 5 callersMethodroot_group_id
(&self)
dolomite/src/cascades/memo.rs:61
↓ 4 callersMethodinputs_len
(&self, ctx: &CascadesOptimizer)
dolomite/src/cascades/task.rs:497
↓ 4 callersMethodoperator
(&self)
dolomite/src/cascades/memo.rs:738
↓ 4 callersMethodreset_root
(&mut self, new_root: PlanNodeRef)
dolomite/src/plan/logical.rs:27
↓ 4 callersMethodschema
(&self)
datafusion-dolomite-integration/tests/utils/schema.rs:96
↓ 4 callersMethodtable
(&self, name: &str)
datafusion-dolomite-integration/tests/utils/schema.rs:80
↓ 4 callersMethodwinner
( &self, physical_prop_set: &PhysicalPropertySet, )
dolomite/src/cascades/memo.rs:582
↓ 3 callersMethodapply
( &self, opt_expr: OptExpression<O>, _ctx: &O, result: &mut RuleResult<O>,
dolomite/src/rules/limit.rs:43
↓ 3 callersFunctionbuild_hep_optimizer_for_test
( tables: HashMap<String, Arc<dyn TableProvider>>, plan: Plan, )
dolomite/src/test_utils.rs:11
↓ 3 callersMethodclone_with_inputs
(&self, operator: Operator)
dolomite/src/rules/opt_expr.rs:122
↓ 3 callersFunctionexplain_to_string
(plan: &Plan)
dolomite/src/plan/explain.rs:34
↓ 3 callersMethodexpr
(&self)
dolomite/src/operator/join.rs:29
↓ 3 callersMethodfind_best_plan
(mut self)
dolomite/src/cascades/optimizer.rs:39
↓ 3 callersFunctionfrom_df_logical
Convert datafusion logical plan to dolomite logical plan.
datafusion-dolomite-integration/src/conversion/logical.rs:33
↓ 3 callersMethodinputs_len
(&self, opt: &HepOptimizer)
dolomite/src/heuristic/graph.rs:126
↓ 3 callersMethodinsert_group_expression
( &mut self, group_expr_key: GroupExprKey, target_group: Option<GroupId>, )
dolomite/src/cascades/memo.rs:127
↓ 3 callersMethodleaf_node
(self, node: Self::Node)
dolomite/src/utils.rs:31
↓ 3 callersMethodnext
(&mut self)
dolomite/src/cascades/binding.rs:41
↓ 3 callersMethodnext_group_expr_id
(&mut self)
dolomite/src/cascades/memo.rs:651
↓ 3 callersMethodoperator
(&self)
dolomite/src/plan/mod.rs:137
↓ 3 callersMethodoperator
(&self)
dolomite/src/heuristic/graph.rs:122
↓ 3 callersMethodoperator_cost
(&self, ctx: &CascadesOptimizer)
dolomite/src/cascades/task.rs:492
↓ 3 callersMethodpattern
(&self)
dolomite/src/rules/limit.rs:60
↓ 3 callersMethodroot_node_id
(&self)
dolomite/src/heuristic/optimizer.rs:115
↓ 3 callersMethodrule_id
(&self)
dolomite/src/rules/join.rs:62
↓ 3 callersMethodtable_name
(&self)
dolomite/src/operator/table_scan.rs:38
↓ 3 callersFunctiontable_schema
(prefix: &str)
datafusion-dolomite-integration/src/planner.rs:78
↓ 2 callersMethodadd_child
(mut self, tree: T)
dolomite/src/utils.rs:73
↓ 2 callersMethodapply
( &self, input: OptExpression<O>, _ctx: &O, result: &mut RuleResult<O>, )
dolomite/src/rules/join.rs:45
↓ 2 callersMethodbfs_iterator
(&self)
dolomite/src/plan/mod.rs:113
↓ 2 callersMethodbind
(self)
dolomite/src/cascades/binding.rs:72
↓ 2 callersMethodbottom_up_node_iters
Return node ids in bottom up order.
dolomite/src/heuristic/graph.rs:46
↓ 2 callersFunctioncreate_optimizer
(plan: Plan)
dolomite/src/cascades/binding.rs:146
↓ 2 callersMethoddisplay
(&self, f: &mut Formatter<'_>)
dolomite/src/operator/join.rs:69
↓ 2 callersMethodexecute
(self, ctx: &mut CascadesOptimizer)
dolomite/src/cascades/task.rs:91
↓ 2 callersMethodexpr_at
(&self, expr_handle: HepNodeId)
dolomite/src/heuristic/optimizer.rs:46
↓ 2 callersMethodget_group_expression
Get group expression indexed by `group_expr_id` without searching duplicated group expression.
dolomite/src/cascades/memo.rs:320
↓ 2 callersMethodhash_join
( mut self, join_type: JoinType, condition: Expr, right: PlanNodeRef, )
dolomite/src/plan/physical.rs:37
↓ 2 callersMethodinput_at
(&self, idx: usize, opt: &HepOptimizer)
dolomite/src/heuristic/graph.rs:133
↓ 2 callersMethodinput_group_ids
(&self)
dolomite/src/cascades/memo.rs:764
↓ 2 callersMethodinsert_group_expr
(&mut self, group_expr: GroupExpr)
dolomite/src/cascades/memo.rs:636
↓ 2 callersMethodinsert_opt_expression
Insert a rule result into memo and return group expression id. Note that some optimizer node maybe extracted from original group expression and remai
dolomite/src/cascades/memo.rs:96
↓ 2 callersMethodinsert_opt_node
( &mut self, opt_expr: &OptExpression<HepOptimizer>, )
dolomite/src/heuristic/optimizer.rs:177
↓ 2 callersMethodis_rule_applied
(&self, rule_id: RuleId)
dolomite/src/cascades/memo.rs:760
↓ 2 callersMethodleaf
(self, node: K)
dolomite/src/utils.rs:27
↓ 2 callersMethodpattern
(&self)
dolomite/src/rules/join.rs:58
↓ 2 callersMethodresults
(self)
dolomite/src/rules/mod.rs:94
↓ 2 callersFunctiontable_source
(prefix: &str)
datafusion-dolomite-integration/src/planner.rs:116
↓ 2 callersMethodupdate_group_ids
Update input group ids using merged group mapping.
dolomite/src/cascades/memo.rs:827
↓ 2 callersMethodupdate_winner
( &mut self, group_expr_id: GroupExprId, output_prop: &PhysicalPropertySet, in
dolomite/src/cascades/memo.rs:605
↓ 1 callersMethodadd_inputs
(mut self, inputs: I)
dolomite/src/plan/mod.rs:180
↓ 1 callersMethodadd_rules
(mut self, rules: impl IntoIterator<Item = RuleImpl>)
datafusion-dolomite-integration/tests/utils/hep_optimizer.rs:48
↓ 1 callersMethodapply_rule
( &mut self, rule: RuleImpl, expr_handle: HepNodeId, )
dolomite/src/heuristic/optimizer.rs:119
↓ 1 callersMethodbegin_node
( self, node: Self::Node, )
dolomite/src/utils.rs:16
↓ 1 callersMethodbest_plan
Find best plan from root group.
dolomite/src/cascades/memo.rs:66
↓ 1 callersMethodbest_plan_of
( &self, prop: &PhysicalPropertySet, memo: &Memo, plan_id_gen: G, )
dolomite/src/cascades/memo.rs:669
↓ 1 callersMethodcontext
(&self)
dolomite/src/cascades/optimizer.rs:27
↓ 1 callersMethodcreate
(&self, plan: Plan)
datafusion-dolomite-integration/tests/utils/hep_optimizer.rs:18
↓ 1 callersFunctioncreate_physical_name
A simplified port of `DefaultPlanner`
datafusion-dolomite-integration/src/conversion/physical.rs:120
↓ 1 callersMethodcreate_physical_plan
( &self, df_logical_plan: &LogicalPlan, session_state: &SessionState, )
datafusion-dolomite-integration/src/planner.rs:29
↓ 1 callersMethoddefault_cost
(&self)
dolomite/src/cost/trivial.rs:27
↓ 1 callersMethodderive_logical_prop
( &self, _handle: O::ExprHandle, _optimizer: &O, )
dolomite/src/operator/mod.rs:48
↓ 1 callersMethodderive_properties
( &self, _context: DerivePropContext<O>, )
dolomite/src/operator/join.rs:35
↓ 1 callersFunctiondf_logical_plan_to_plan_node
( df_plan: &LogicalPlan, id_gen: &mut PlanNodeIdGen, )
datafusion-dolomite-integration/src/conversion/logical.rs:100
↓ 1 callersMethoddo_after_optimize_input
( mut self, ctx: &CascadesOptimizer, )
dolomite/src/cascades/task.rs:328
↓ 1 callersMethoddo_before_optimize_input
( mut self, ctx: &CascadesOptimizer, )
dolomite/src/cascades/task.rs:289
↓ 1 callersMethoddo_init
(mut self, ctx: &mut CascadesOptimizer)
dolomite/src/cascades/task.rs:248
↓ 1 callersMethoddo_optimize_self
( mut self, ctx: &mut CascadesOptimizer, )
dolomite/src/cascades/task.rs:403
↓ 1 callersFunctionexplain
(plan: &Plan, output: &mut W)
dolomite/src/plan/explain.rs:25
↓ 1 callersMethodexpr_count
Number of group expressions.
dolomite/src/cascades/memo.rs:632
↓ 1 callersFunctionexpr_to_df_join_condition
( expr: &Expr, )
datafusion-dolomite-integration/src/conversion/mod.rs:13
↓ 1 callersMethodformat
(&self, f: &mut Formatter<'_>, level: usize)
dolomite/src/rules/opt_expr.rs:162
↓ 1 callersMethodgen_next
(&mut self)
dolomite/src/plan/mod.rs:34
↓ 1 callersMethodhash_join_cost
(&self, _join: &Join)
dolomite/src/cost/trivial.rs:23
↓ 1 callersMethodinit_with_plan
(&mut self, plan: Plan)
dolomite/src/heuristic/optimizer.rs:217
↓ 1 callersMethodis_logical
(&self)
dolomite/src/cascades/memo.rs:793
next →1–100 of 263, ranked by callers