Home
last modified time | relevance | path

Searched refs:PhysicalExpr (Results 1 – 25 of 34) sorted by relevance

12

/dports/www/grafana8/grafana-8.3.6/vendor/github.com/apache/arrow/rust/datafusion/src/physical_plan/expressions/
H A Dis_not_null.rs28 use crate::physical_plan::{ColumnarValue, PhysicalExpr};
35 arg: Arc<dyn PhysicalExpr>,
40 pub fn new(arg: Arc<dyn PhysicalExpr>) -> Self { in new()
45 pub fn arg(&self) -> &Arc<dyn PhysicalExpr> { in arg() argument
56 impl PhysicalExpr for IsNotNullExpr {
84 pub fn is_not_null(arg: Arc<dyn PhysicalExpr>) -> Result<Arc<dyn PhysicalExpr>> { in is_not_null() argument
H A Dis_null.rs28 use crate::physical_plan::{ColumnarValue, PhysicalExpr};
35 arg: Arc<dyn PhysicalExpr>,
40 pub fn new(arg: Arc<dyn PhysicalExpr>) -> Self { in new()
45 pub fn arg(&self) -> &Arc<dyn PhysicalExpr> { in arg() argument
56 impl PhysicalExpr for IsNullExpr {
84 pub fn is_null(arg: Arc<dyn PhysicalExpr>) -> Result<Arc<dyn PhysicalExpr>> { in is_null() argument
H A Dnegative.rs32 use crate::physical_plan::{ColumnarValue, PhysicalExpr};
52 arg: Arc<dyn PhysicalExpr>,
57 pub fn new(arg: Arc<dyn PhysicalExpr>) -> Self { in new()
62 pub fn arg(&self) -> &Arc<dyn PhysicalExpr> { in arg() argument
73 impl PhysicalExpr for NegativeExpr {
119 arg: Arc<dyn PhysicalExpr>, in negative() argument
121 ) -> Result<Arc<dyn PhysicalExpr>> { in negative() argument
H A Dcase.rs47 expr: Option<Arc<dyn PhysicalExpr>>,
49 when_then_expr: Vec<(Arc<dyn PhysicalExpr>, Arc<dyn PhysicalExpr>)>,
51 else_expr: Option<Arc<dyn PhysicalExpr>>,
73 expr: Option<Arc<dyn PhysicalExpr>>, in try_new() argument
74 when_then_expr: &[(Arc<dyn PhysicalExpr>, Arc<dyn PhysicalExpr>)], in try_new() argument
96 pub fn when_then_expr(&self) -> &[(Arc<dyn PhysicalExpr>, Arc<dyn PhysicalExpr>)] { in when_then_expr() argument
407 impl PhysicalExpr for CaseExpr {
448 expr: Option<Arc<dyn PhysicalExpr>>, in case() argument
449 when_thens: &[(Arc<dyn PhysicalExpr>, Arc<dyn PhysicalExpr>)], in case() argument
450 else_expr: Option<Arc<dyn PhysicalExpr>>, in case() argument
[all …]
H A Dnot.rs26 use crate::physical_plan::PhysicalExpr;
36 arg: Arc<dyn PhysicalExpr>,
41 pub fn new(arg: Arc<dyn PhysicalExpr>) -> Self { in new()
46 pub fn arg(&self) -> &Arc<dyn PhysicalExpr> { in arg() argument
57 impl PhysicalExpr for NotExpr {
105 arg: Arc<dyn PhysicalExpr>, in not() argument
107 ) -> Result<Arc<dyn PhysicalExpr>> { in not() argument
H A Dcast.rs24 use crate::physical_plan::PhysicalExpr;
36 expr: Arc<dyn PhysicalExpr>,
43 pub fn new(expr: Arc<dyn PhysicalExpr>, cast_type: DataType) -> Self { in new() argument
48 pub fn expr(&self) -> &Arc<dyn PhysicalExpr> { in expr() argument
64 impl PhysicalExpr for CastExpr {
100 expr: Arc<dyn PhysicalExpr>, in cast() argument
103 ) -> Result<Arc<dyn PhysicalExpr>> { in cast() argument
H A Din_list.rs35 use crate::physical_plan::{ColumnarValue, PhysicalExpr};
41 expr: Arc<dyn PhysicalExpr>,
42 list: Vec<Arc<dyn PhysicalExpr>>,
105 expr: Arc<dyn PhysicalExpr>, in new() argument
106 list: Vec<Arc<dyn PhysicalExpr>>, in new() argument
117 pub fn expr(&self) -> &Arc<dyn PhysicalExpr> { in expr() argument
122 pub fn list(&self) -> &[Arc<dyn PhysicalExpr>] { in list() argument
207 impl PhysicalExpr for InListExpr {
282 expr: Arc<dyn PhysicalExpr>, in in_list() argument
283 list: Vec<Arc<dyn PhysicalExpr>>, in in_list() argument
[all …]
H A Dcolumn.rs28 use crate::physical_plan::{ColumnarValue, PhysicalExpr};
56 impl PhysicalExpr for Column {
84 pub fn col(name: &str) -> Arc<dyn PhysicalExpr> { in col() argument
H A Dbinary.rs51 left: Arc<dyn PhysicalExpr>,
53 right: Arc<dyn PhysicalExpr>,
59 left: Arc<dyn PhysicalExpr>, in new() argument
61 right: Arc<dyn PhysicalExpr>, in new() argument
539 lhs: Arc<dyn PhysicalExpr>, in binary_cast() argument
541 rhs: Arc<dyn PhysicalExpr>, in binary_cast() argument
543 ) -> Result<(Arc<dyn PhysicalExpr>, Arc<dyn PhysicalExpr>)> { in binary_cast() argument
559 lhs: Arc<dyn PhysicalExpr>, in binary() argument
561 rhs: Arc<dyn PhysicalExpr>, in binary() argument
580 l: Arc<dyn PhysicalExpr>, in binary_simple() argument
[all …]
H A Dliteral.rs28 use crate::physical_plan::{ColumnarValue, PhysicalExpr};
55 impl PhysicalExpr for Literal {
75 pub fn lit(value: ScalarValue) -> Arc<dyn PhysicalExpr> { in lit() argument
H A Dcount.rs24 use crate::physical_plan::{Accumulator, AggregateExpr, PhysicalExpr};
42 expr: Arc<dyn PhysicalExpr>,
47 pub fn new(expr: Arc<dyn PhysicalExpr>, name: String, data_type: DataType) -> Self { in new() argument
79 fn expressions(&self) -> Vec<Arc<dyn PhysicalExpr>> { in expressions() argument
H A Daverage.rs25 use crate::physical_plan::{Accumulator, AggregateExpr, PhysicalExpr};
42 expr: Arc<dyn PhysicalExpr>,
67 pub fn new(expr: Arc<dyn PhysicalExpr>, name: String, data_type: DataType) -> Self { in new() argument
109 fn expressions(&self) -> Vec<Arc<dyn PhysicalExpr>> { in expressions() argument
H A Dmin_max.rs25 use crate::physical_plan::{Accumulator, AggregateExpr, PhysicalExpr};
46 expr: Arc<dyn PhysicalExpr>,
51 pub fn new(expr: Arc<dyn PhysicalExpr>, name: String, data_type: DataType) -> Self { in new() argument
83 fn expressions(&self) -> Vec<Arc<dyn PhysicalExpr>> { in expressions() argument
303 expr: Arc<dyn PhysicalExpr>,
308 pub fn new(expr: Arc<dyn PhysicalExpr>, name: String, data_type: DataType) -> Self { in new() argument
340 fn expressions(&self) -> Vec<Arc<dyn PhysicalExpr>> { in expressions() argument
H A Dmod.rs24 use crate::physical_plan::PhysicalExpr;
70 pub expr: Arc<dyn PhysicalExpr>,
/dports/www/grafana8/grafana-8.3.6/vendor/github.com/apache/arrow/rust/datafusion/src/physical_plan/
H A Dfilter.rs28 use crate::physical_plan::{ExecutionPlan, Partitioning, PhysicalExpr};
44 predicate: Arc<dyn PhysicalExpr>,
52 predicate: Arc<dyn PhysicalExpr>, in try_new() argument
68 pub fn predicate(&self) -> &Arc<dyn PhysicalExpr> { in predicate() argument
130 predicate: Arc<dyn PhysicalExpr>,
137 predicate: &Arc<dyn PhysicalExpr>, in batch_filter() argument
205 let predicate: Arc<dyn PhysicalExpr> = binary( in simple_predicate()
H A Dprojection.rs29 use crate::physical_plan::{ExecutionPlan, Partitioning, PhysicalExpr};
44 expr: Vec<(Arc<dyn PhysicalExpr>, String)>,
54 expr: Vec<(Arc<dyn PhysicalExpr>, String)>, in try_new() argument
80 pub fn expr(&self) -> &[(Arc<dyn PhysicalExpr>, String)] { in expr() argument
137 expressions: &[Arc<dyn PhysicalExpr>], in batch_project() argument
154 expr: Vec<Arc<dyn PhysicalExpr>>,
H A Dudaf.rs29 use crate::physical_plan::PhysicalExpr;
106 args: &[Arc<dyn PhysicalExpr>], in create_aggregate_expr() argument
130 args: Vec<Arc<dyn PhysicalExpr>>,
141 fn expressions(&self) -> Vec<Arc<dyn PhysicalExpr>> { in expressions() argument
H A Dudf.rs26 use crate::{logical_plan::Expr, physical_plan::PhysicalExpr};
95 args: &[Arc<dyn PhysicalExpr>], in create_physical_expr() argument
97 ) -> Result<Arc<dyn PhysicalExpr>> { in create_physical_expr() argument
H A Dhash_aggregate.rs84 group_expr: Vec<(Arc<dyn PhysicalExpr>, String)>,
99 group_expr: &[(Arc<dyn PhysicalExpr>, String)], in create_schema() argument
134 group_expr: Vec<(Arc<dyn PhysicalExpr>, String)>, in try_new() argument
283 group_expr: &[Arc<dyn PhysicalExpr>], in group_aggregate_batch() argument
582 group_expr: Vec<Arc<dyn PhysicalExpr>>, in compute_grouped_hash_aggregate() argument
619 group_expr: Vec<Arc<dyn PhysicalExpr>>, in new() argument
689 expr: &[Arc<dyn PhysicalExpr>], in evaluate() argument
700 expr: &[Vec<Arc<dyn PhysicalExpr>>], in evaluate_many() argument
711 ) -> Result<Vec<Arc<dyn PhysicalExpr>>> { in merge_expressions() argument
729 ) -> Result<Vec<Vec<Arc<dyn PhysicalExpr>>>> { in aggregate_expressions() argument
[all …]
H A Dmod.rs135 Hash(Vec<Arc<dyn PhysicalExpr>>, usize),
188 pub trait PhysicalExpr: Send + Sync + Display + Debug { interface
223 fn expressions(&self) -> Vec<Arc<dyn PhysicalExpr>>; in expressions() argument
/dports/security/vault/vault-1.8.2/vendor/github.com/apache/arrow/rust/datafusion/src/execution/physical_plan/
H A Dselection.rs24 BatchIterator, ExecutionPlan, Partition, PhysicalExpr,
34 expr: Arc<dyn PhysicalExpr>,
42 expr: Arc<dyn PhysicalExpr>, in try_new() argument
84 expr: Arc<dyn PhysicalExpr>,
102 expr: Arc<dyn PhysicalExpr>,
165 let predicate: Arc<dyn PhysicalExpr> = binary( in simple_predicate()
H A Dudf.rs24 use crate::execution::physical_plan::PhysicalExpr;
66 args: Vec<Arc<dyn PhysicalExpr>>,
75 args: Vec<Arc<dyn PhysicalExpr>>, in new() argument
87 impl PhysicalExpr for ScalarFunctionExpr {
H A Dprojection.rs27 BatchIterator, ExecutionPlan, Partition, PhysicalExpr,
35 expr: Vec<Arc<dyn PhysicalExpr>>,
45 expr: Vec<Arc<dyn PhysicalExpr>>, in try_new() argument
96 expr: Vec<Arc<dyn PhysicalExpr>>,
114 expr: Vec<Arc<dyn PhysicalExpr>>,
H A Dexpressions.rs51 expr: Arc<dyn PhysicalExpr>,
65 impl PhysicalExpr for Alias {
95 impl PhysicalExpr for Column {
119 expr: Arc<dyn PhysicalExpr>,
315 expr: Arc<dyn PhysicalExpr>,
433 expr: Arc<dyn PhysicalExpr>,
1080 l: Arc<dyn PhysicalExpr>, in binary() argument
1082 r: Arc<dyn PhysicalExpr>, in binary() argument
1083 ) -> Arc<dyn PhysicalExpr> { in binary() argument
1089 arg: Arc<dyn PhysicalExpr>,
[all …]
H A Dhash_aggregate.rs26 Accumulator, AggregateExpr, BatchIterator, ExecutionPlan, Partition, PhysicalExpr,
47 group_expr: Vec<Arc<dyn PhysicalExpr>>,
56 group_expr: Vec<Arc<dyn PhysicalExpr>>, in try_new() argument
85 ) -> (Vec<Arc<dyn PhysicalExpr>>, Vec<Arc<dyn AggregateExpr>>) { in make_final_expr() argument
86 let final_group: Vec<Arc<dyn PhysicalExpr>> = (0..self.group_expr.len()) in make_final_expr()
89 as Arc<dyn PhysicalExpr> in make_final_expr()
130 group_expr: Vec<Arc<dyn PhysicalExpr>>,
139 group_expr: Vec<Arc<dyn PhysicalExpr>>, in new() argument
247 group_expr: Vec<Arc<dyn PhysicalExpr>>,
257 group_expr: Vec<Arc<dyn PhysicalExpr>>, in new() argument
[all …]

12