Home
last modified time | relevance | path

Searched refs:ExecutionPlan (Results 1 – 25 of 143) sorted by relevance

123456

/dports/www/grafana8/grafana-8.3.6/vendor/github.com/apache/arrow/rust/datafusion/src/physical_plan/
H A Dlimit.rs44 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 Dfilter.rs28 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 Dmerge.rs39 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 Dprojection.rs29 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 Dcoalesce_batches.rs28 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 Dexplain.rs26 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 Dmod.rs57 ) -> 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 Dmemory.rs24 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 Drepartition.rs27 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 Dempty.rs25 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 Dsort.rs40 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 Dhash_join.rs74 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 Dplanner.rs62 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 Dresults.cc60 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 Dresults.h42 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 Dresults.cc60 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 Dresults.h42 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 Dflow_workspace.cpp40 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 Dprovider_filter_pushdown.rs29 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 Dcustom_sources.rs32 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 Duser_defined_plan.rs78 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 Dselection.rs24 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 Dprojection.rs27 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 Dstruct_hierarchy_info.go30 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 Dstruct_hierarchy_info.go30 ExecutionPlan ExecutionPlan `json:"ExecutionPlan" xml:"ExecutionPlan"` member

123456