/dports/www/grafana8/grafana-8.3.6/vendor/github.com/apache/arrow/rust/datafusion/src/physical_plan/expressions/ |
H A D | is_not_null.rs | 28 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 D | is_null.rs | 28 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 D | negative.rs | 32 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 D | case.rs | 47 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 D | not.rs | 26 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 D | cast.rs | 24 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 D | in_list.rs | 35 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 D | column.rs | 28 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 D | binary.rs | 51 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 D | literal.rs | 28 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 D | count.rs | 24 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 D | average.rs | 25 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 D | min_max.rs | 25 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 D | mod.rs | 24 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 D | filter.rs | 28 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 D | projection.rs | 29 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 D | udaf.rs | 29 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 D | udf.rs | 26 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 D | hash_aggregate.rs | 84 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 D | mod.rs | 135 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 D | selection.rs | 24 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 D | udf.rs | 24 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 D | projection.rs | 27 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 D | expressions.rs | 51 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 D | hash_aggregate.rs | 26 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 …]
|