/dports/www/grafana8/grafana-8.3.6/vendor/github.com/apache/arrow/rust/datafusion/src/physical_plan/ |
H A D | limit.rs | 44 input: Arc<dyn ExecutionPlan>, 56 pub fn input(&self) -> &Arc<dyn ExecutionPlan> { in input() argument 67 impl ExecutionPlan for GlobalLimitExec { 77 fn children(&self) -> Vec<Arc<dyn ExecutionPlan>> { in children() argument 92 children: Vec<Arc<dyn ExecutionPlan>>, in with_new_children() argument 93 ) -> Result<Arc<dyn ExecutionPlan>> { in with_new_children() argument 130 input: Arc<dyn ExecutionPlan>, 142 pub fn input(&self) -> &Arc<dyn ExecutionPlan> { in input() argument 153 impl ExecutionPlan for LocalLimitExec { 173 children: Vec<Arc<dyn ExecutionPlan>>, in with_new_children() argument [all …]
|
H A D | filter.rs | 28 use crate::physical_plan::{ExecutionPlan, Partitioning, PhysicalExpr}; 46 input: Arc<dyn ExecutionPlan>, 53 input: Arc<dyn ExecutionPlan>, in try_new() argument 73 pub fn input(&self) -> &Arc<dyn ExecutionPlan> { in input() argument 79 impl ExecutionPlan for FilterExec { 91 fn children(&self) -> Vec<Arc<dyn ExecutionPlan>> { in children() argument 102 children: Vec<Arc<dyn ExecutionPlan>>, in with_new_children() argument 103 ) -> Result<Arc<dyn ExecutionPlan>> { in with_new_children() argument 189 use crate::physical_plan::ExecutionPlan; 222 let filter: Arc<dyn ExecutionPlan> = in simple_predicate()
|
H A D | merge.rs | 39 use crate::physical_plan::ExecutionPlan; 50 input: Arc<dyn ExecutionPlan>, 55 pub fn new(input: Arc<dyn ExecutionPlan>) -> Self { in new() 60 pub fn input(&self) -> &Arc<dyn ExecutionPlan> { in input() argument 66 impl ExecutionPlan for MergeExec { 76 fn children(&self) -> Vec<Arc<dyn ExecutionPlan>> { in children() argument 87 children: Vec<Arc<dyn ExecutionPlan>>, in with_new_children() argument 88 ) -> Result<Arc<dyn ExecutionPlan>> { in with_new_children() argument
|
H A D | projection.rs | 29 use crate::physical_plan::{ExecutionPlan, Partitioning, PhysicalExpr}; 48 input: Arc<dyn ExecutionPlan>, 55 input: Arc<dyn ExecutionPlan>, in try_new() argument 85 pub fn input(&self) -> &Arc<dyn ExecutionPlan> { in input() argument 91 impl ExecutionPlan for ProjectionExec { 102 fn children(&self) -> Vec<Arc<dyn ExecutionPlan>> { in children() argument 113 children: Vec<Arc<dyn ExecutionPlan>>, in with_new_children() argument 114 ) -> Result<Arc<dyn ExecutionPlan>> { in with_new_children() argument
|
H A D | coalesce_batches.rs | 28 ExecutionPlan, Partitioning, RecordBatchStream, SendableRecordBatchStream, 44 input: Arc<dyn ExecutionPlan>, 51 pub fn new(input: Arc<dyn ExecutionPlan>, target_batch_size: usize) -> Self { in new() argument 59 pub fn input(&self) -> &Arc<dyn ExecutionPlan> { in input() argument 70 impl ExecutionPlan for CoalesceBatchesExec { 82 fn children(&self) -> Vec<Arc<dyn ExecutionPlan>> { in children() argument 94 children: Vec<Arc<dyn ExecutionPlan>>, in with_new_children() argument 95 ) -> Result<Arc<dyn ExecutionPlan>> { in with_new_children() argument 290 let exec: Arc<dyn ExecutionPlan> = in coalesce_batches()
|
H A D | explain.rs | 26 physical_plan::{common::SizedRecordBatchStream, ExecutionPlan}, 62 impl ExecutionPlan for ExplainExec { 72 fn children(&self) -> Vec<Arc<dyn ExecutionPlan>> { in children() argument 84 children: Vec<Arc<dyn ExecutionPlan>>, in with_new_children() argument 85 ) -> Result<Arc<dyn ExecutionPlan>> { in with_new_children() argument
|
H A D | mod.rs | 57 ) -> Result<Arc<dyn ExecutionPlan>>; in create_physical_plan() argument 62 pub trait ExecutionPlan: Debug + Send + Sync { interface 77 fn children(&self) -> Vec<Arc<dyn ExecutionPlan>>; in children() argument 82 children: Vec<Arc<dyn ExecutionPlan>>, in with_new_children() argument 83 ) -> Result<Arc<dyn ExecutionPlan>>; in with_new_children() argument 90 pub async fn collect(plan: Arc<dyn ExecutionPlan>) -> Result<Vec<RecordBatch>> { in collect() 109 plan: Arc<dyn ExecutionPlan>, in collect_partitioned() argument
|
H A D | memory.rs | 24 use super::{ExecutionPlan, Partitioning, RecordBatchStream, SendableRecordBatchStream}; 45 impl ExecutionPlan for MemoryExec { 56 fn children(&self) -> Vec<Arc<dyn ExecutionPlan>> { in children() argument 68 _: Vec<Arc<dyn ExecutionPlan>>, in with_new_children() argument 69 ) -> Result<Arc<dyn ExecutionPlan>> { in with_new_children() argument
|
H A D | repartition.rs | 27 use crate::physical_plan::{ExecutionPlan, Partitioning}; 48 input: Arc<dyn ExecutionPlan>, 58 pub fn input(&self) -> &Arc<dyn ExecutionPlan> { in input() argument 69 impl ExecutionPlan for RepartitionExec { 80 fn children(&self) -> Vec<Arc<dyn ExecutionPlan>> { in children() argument 86 children: Vec<Arc<dyn ExecutionPlan>>, in with_new_children() argument 87 ) -> Result<Arc<dyn ExecutionPlan>> { in with_new_children() argument 181 input: Arc<dyn ExecutionPlan>, in try_new() argument
|
H A D | empty.rs | 25 use crate::physical_plan::{Distribution, ExecutionPlan, Partitioning}; 59 impl ExecutionPlan for EmptyExec { 69 fn children(&self) -> Vec<Arc<dyn ExecutionPlan>> { in children() argument 84 children: Vec<Arc<dyn ExecutionPlan>>, in with_new_children() argument 85 ) -> Result<Arc<dyn ExecutionPlan>> { in with_new_children() argument
|
H A D | sort.rs | 40 use crate::physical_plan::{common, Distribution, ExecutionPlan, Partitioning}; 48 input: Arc<dyn ExecutionPlan>, 57 input: Arc<dyn ExecutionPlan>, in try_new() argument 63 pub fn input(&self) -> &Arc<dyn ExecutionPlan> { in input() argument 74 impl ExecutionPlan for SortExec { 84 fn children(&self) -> Vec<Arc<dyn ExecutionPlan>> { in children() argument 99 children: Vec<Arc<dyn ExecutionPlan>>, in with_new_children() argument 100 ) -> Result<Arc<dyn ExecutionPlan>> { in with_new_children() argument
|
H A D | hash_join.rs | 74 left: Arc<dyn ExecutionPlan>, 76 right: Arc<dyn ExecutionPlan>, 102 left: Arc<dyn ExecutionPlan>, in try_new() argument 103 right: Arc<dyn ExecutionPlan>, in try_new() argument 137 pub fn left(&self) -> &Arc<dyn ExecutionPlan> { in left() argument 188 impl ExecutionPlan for HashJoinExec { 203 children: Vec<Arc<dyn ExecutionPlan>>, in with_new_children() argument 204 ) -> Result<Arc<dyn ExecutionPlan>> { in with_new_children() argument 817 ) -> Arc<dyn ExecutionPlan> { in build_table() argument 824 left: Arc<dyn ExecutionPlan>, in join() argument [all …]
|
H A D | planner.rs | 62 inputs: &[Arc<dyn ExecutionPlan>], in plan_extension() argument 64 ) -> Result<Option<Arc<dyn ExecutionPlan>>>; in plan_extension() argument 87 ) -> Result<Arc<dyn ExecutionPlan>> { in create_physical_plan() argument 107 plan: Arc<dyn ExecutionPlan>, in optimize_plan() argument 109 ) -> Result<Arc<dyn ExecutionPlan>> { in optimize_plan() argument 171 ) -> Result<Arc<dyn ExecutionPlan>> { in create_initial_plan() argument 1057 impl ExecutionPlan for NoOpExecutionPlan { 1077 _children: Vec<Arc<dyn ExecutionPlan>>, in with_new_children() argument 1078 ) -> Result<Arc<dyn ExecutionPlan>> { in with_new_children() argument 1096 _inputs: &[Arc<dyn ExecutionPlan>], in plan_extension() argument [all …]
|
/dports/devel/google-cloud-cpp117/google-cloud-cpp-1.17.0/google/cloud/spanner/ |
H A D | results.cc | 60 absl::optional<spanner::ExecutionPlan> GetExecutionPlan( in GetExecutionPlan() 91 absl::optional<spanner::ExecutionPlan> ProfileQueryResult::ExecutionPlan() in ExecutionPlan() function in google::cloud::spanner::SPANNER_CLIENT_NS::ProfileQueryResult 101 absl::optional<spanner::ExecutionPlan> ProfileDmlResult::ExecutionPlan() const { in ExecutionPlan() function in google::cloud::spanner::SPANNER_CLIENT_NS::ProfileDmlResult
|
H A D | results.h | 42 using ExecutionPlan = ::google::spanner::v1::QueryPlan; variable 192 absl::optional<spanner::ExecutionPlan> ExecutionPlan() const; 242 absl::optional<spanner::ExecutionPlan> ExecutionPlan() const;
|
/dports/devel/google-cloud-cpp/google-cloud-cpp-1.21.0/google/cloud/spanner/ |
H A D | results.cc | 60 absl::optional<spanner::ExecutionPlan> GetExecutionPlan( in GetExecutionPlan() 91 absl::optional<spanner::ExecutionPlan> ProfileQueryResult::ExecutionPlan() in ExecutionPlan() function in google::cloud::spanner::SPANNER_CLIENT_NS::ProfileQueryResult 101 absl::optional<spanner::ExecutionPlan> ProfileDmlResult::ExecutionPlan() const { in ExecutionPlan() function in google::cloud::spanner::SPANNER_CLIENT_NS::ProfileDmlResult
|
H A D | results.h | 42 using ExecutionPlan = ::google::spanner::v1::QueryPlan; variable 192 absl::optional<spanner::ExecutionPlan> ExecutionPlan() const; 242 absl::optional<spanner::ExecutionPlan> ExecutionPlan() const;
|
/dports/science/ascent/ascent-0.7.1-66-gbcf2742a/src/flow/ |
H A D | flow_workspace.cpp | 40 class Workspace::ExecutionPlan class in flow::Workspace 48 ExecutionPlan(); 49 ~ExecutionPlan(); 76 Workspace::ExecutionPlan::ExecutionPlan() in ExecutionPlan() function in flow::Workspace::ExecutionPlan 82 Workspace::ExecutionPlan::~ExecutionPlan() in ~ExecutionPlan() 90 Workspace::ExecutionPlan::generate(Graph &graph, in generate() 153 Workspace::ExecutionPlan::bf_topo_sort_visit(Graph &graph, in bf_topo_sort_visit() 263 ExecutionPlan::generate(graph(),traversals); in traversals() 272 ExecutionPlan::generate(graph(),traversals); in execute()
|
/dports/www/grafana8/grafana-8.3.6/vendor/github.com/apache/arrow/rust/datafusion/tests/ |
H A D | provider_filter_pushdown.rs | 29 use datafusion::physical_plan::{ExecutionPlan, Partitioning, SendableRecordBatchStream}; 57 impl ExecutionPlan for CustomPlan { 70 fn children(&self) -> Vec<Arc<dyn ExecutionPlan>> { in children() argument 76 _: Vec<Arc<dyn ExecutionPlan>>, in with_new_children() argument 77 ) -> Result<Arc<dyn ExecutionPlan>> { in with_new_children() argument 109 ) -> Result<Arc<dyn ExecutionPlan>> { in scan() argument
|
H A D | custom_sources.rs | 32 ExecutionPlan, Partitioning, RecordBatchStream, SendableRecordBatchStream, 97 impl ExecutionPlan for CustomExecutionPlan { 113 fn children(&self) -> Vec<Arc<dyn ExecutionPlan>> { in children() argument 118 children: Vec<Arc<dyn ExecutionPlan>>, in with_new_children() argument 119 ) -> Result<Arc<dyn ExecutionPlan>> { in with_new_children() argument 147 ) -> Result<Arc<dyn ExecutionPlan>> { in scan() argument
|
H A D | user_defined_plan.rs | 78 Distribution, ExecutionPlan, Partitioning, PhysicalPlanner, RecordBatchStream, 199 ) -> Result<Arc<dyn ExecutionPlan>> { in create_physical_plan() argument 308 inputs: &[Arc<dyn ExecutionPlan>], in plan_extension() argument 310 ) -> Result<Option<Arc<dyn ExecutionPlan>>> { in plan_extension() argument 329 input: Arc<dyn ExecutionPlan>, 341 impl ExecutionPlan for TopKExec { 359 fn children(&self) -> Vec<Arc<dyn ExecutionPlan>> { in children() argument 365 children: Vec<Arc<dyn ExecutionPlan>>, in with_new_children() argument 366 ) -> Result<Arc<dyn ExecutionPlan>> { in with_new_children() 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, 36 input: Arc<dyn ExecutionPlan>, 43 input: Arc<dyn ExecutionPlan>, in try_new() argument 52 impl ExecutionPlan for SelectionExec { 150 use crate::execution::physical_plan::ExecutionPlan; 179 let selection: Arc<dyn ExecutionPlan> = in simple_predicate()
|
H A D | projection.rs | 27 BatchIterator, ExecutionPlan, Partition, PhysicalExpr, 39 input: Arc<dyn ExecutionPlan>, 46 input: Arc<dyn ExecutionPlan>, in try_new() argument 65 impl ExecutionPlan for ProjectionExec {
|
/dports/security/vault/vault-1.8.2/vendor/github.com/aliyun/alibaba-cloud-sdk-go/services/emr/ |
H A D | struct_hierarchy_info.go | 30 ExecutionPlan ExecutionPlan `json:"ExecutionPlan" xml:"ExecutionPlan"` member
|
/dports/sysutils/terraform/terraform-1.0.11/vendor/github.com/aliyun/alibaba-cloud-sdk-go/services/emr/ |
H A D | struct_hierarchy_info.go | 30 ExecutionPlan ExecutionPlan `json:"ExecutionPlan" xml:"ExecutionPlan"` member
|