A platform for high-performance distributed tool and library development written in C++. It can be deployed in two different cluster modes: standalone or distributed. API for v0.5.0, released on June 13, 2018.
 All Classes Namespaces Files Functions Variables Typedefs Enumerations Enumerator Friends Macros
AdvancedPhysicalAggregationPipe.cc
Go to the documentation of this file.
1 /*****************************************************************************
2  * *
3  * Copyright 2018 Rice University *
4  * *
5  * Licensed under the Apache License, Version 2.0 (the "License"); *
6  * you may not use this file except in compliance with the License. *
7  * You may obtain a copy of the License at *
8  * *
9  * http://www.apache.org/licenses/LICENSE-2.0 *
10  * *
11  * Unless required by applicable law or agreed to in writing, software *
12  * distributed under the License is distributed on an "AS IS" BASIS, *
13  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. *
14  * See the License for the specific language governing permissions and *
15  * limitations under the License. *
16  * *
17  *****************************************************************************/
18 
19 
23 
24 namespace pdb {
25 
27  Handle<ComputePlan> &computePlan,
28  LogicalPlanPtr &logicalPlan,
29  ConfigurationPtr &conf,
30  vector<AtomicComputationPtr> &pipeComputations,
31  size_t id) :
33  computePlan,
34  logicalPlan,
35  conf,
36  pipeComputations,
37  id) {}
38 
40  selectedAlgorithm = std::make_shared<AdvancedPhysicalAggregationPipelineAlgorithm>(getAdvancedPhysicalNodeHandle(),
41  jobId,
42  isJoining(),
43  consumers.empty(),
47  conf);
48  return selectedAlgorithm;
49 }
50 
51 vector<AdvancedPhysicalAbstractAlgorithmPtr> AdvancedPhysicalAggregationPipe::getPossibleAlgorithms(const StatisticsPtr &stats) {
52 
53  // currently every straight pipeline is realized as a selection
54  std::vector<AdvancedPhysicalAbstractAlgorithmPtr> ret = { std::make_shared<AdvancedPhysicalAggregationPipelineAlgorithm>(getAdvancedPhysicalNodeHandle(),
55  jobId,
56  isJoining(),
57  consumers.empty(),
61  conf) };
62 
63  return ret;
64 }
65 
67  return AGGREGATION;
68 }
69 
70 }
71 
Handle< ComputePlan > computePlan
std::shared_ptr< Statistics > StatisticsPtr
Definition: Statistics.h:27
AdvancedPhysicalAbstractAlgorithmPtr selectOutputAlgorithm() override
AdvancedPhysicalPipelineNodePtr getAdvancedPhysicalNodeHandle()
AdvancedPhysicalAbstractAlgorithmPtr selectedAlgorithm
std::shared_ptr< LogicalPlan > LogicalPlanPtr
Definition: ComputePlan.h:36
vector< AdvancedPhysicalAbstractAlgorithmPtr > getPossibleAlgorithms(const StatisticsPtr &stats) override
shared_ptr< Configuration > ConfigurationPtr
Definition: Configuration.h:89
std::list< AbstractPhysicalNodePtr > consumers
AdvancedPhysicalPipelineTypeID getType() override
AdvancedPhysicalAggregationPipe(string &jobId, Handle< ComputePlan > &computePlan, LogicalPlanPtr &logicalPlan, ConfigurationPtr &conf, vector< AtomicComputationPtr > &pipeComputations, size_t id)
std::shared_ptr< AdvancedPhysicalAbstractAlgorithm > AdvancedPhysicalAbstractAlgorithmPtr