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.
|
#include <SimplePhysicalAggregationNode.h>
Protected Member Functions | |
PhysicalOptimizerResultPtr | analyzeSingleConsumer (TupleSetJobStageBuilderPtr &tupleStageBuilder, SimplePhysicalNodePtr &prevNode, const StatisticsPtr &stats, int nextStageID) override |
PhysicalOptimizerResultPtr | analyzeOutput (TupleSetJobStageBuilderPtr &tupleStageBuilder, SimplePhysicalNodePtr &prevNode, const StatisticsPtr &stats, int nextStageID) override |
PhysicalOptimizerResultPtr | analyzeMultipleConsumers (TupleSetJobStageBuilderPtr &tupleStageBuilder, SimplePhysicalNodePtr &prevNode, const StatisticsPtr &stats, int nextStageID) override |
Protected Member Functions inherited from pdb::SimplePhysicalNode | |
std::string | getNodeIdentifier () override |
double | getCost (Handle< SetIdentifier > source, const StatisticsPtr &stats) |
const Handle< SetIdentifier > & | getSourceSetIdentifier () const |
Protected Member Functions inherited from pdb::AbstractPhysicalNode | |
Handle< SetIdentifier > | getSetIdentifierFromComputation (Handle< Computation > computation) |
Additional Inherited Members | |
Protected Attributes inherited from pdb::SimplePhysicalNode | |
std::list< SimplePhysicalNodePtr > | activeConsumers |
Handle< SetIdentifier > | sourceSetIdentifier |
AtomicComputationPtr | node |
Protected Attributes inherited from pdb::AbstractPhysicalNode | |
std::string | jobId |
Handle< ComputePlan > | computePlan |
LogicalPlanPtr | logicalPlan |
ConfigurationPtr | conf |
std::list < AbstractPhysicalNodePtr > | consumers |
std::list < AbstractPhysicalNodeWeakPtr > | producers |
AbstractPhysicalNodeWeakPtr | handle |
Definition at line 26 of file SimplePhysicalAggregationNode.h.
pdb::SimplePhysicalAggregationNode::SimplePhysicalAggregationNode | ( | string | jobId, |
AtomicComputationPtr | node, | ||
const Handle< ComputePlan > & | computePlan, | ||
LogicalPlanPtr | logicalPlan, | ||
ConfigurationPtr | conf | ||
) |
Definition at line 25 of file SimplePhysicalAggregationNode.cc.
|
overrideprotectedvirtual |
In the case that this aggregation has only one consumer this method is called. It essentially builds the
tupleStageBuilder | - the builder for the tuple set job stage, that contains all the computations in our pipeline so far. |
prevNode | - the previous node we are coming from to analyze this node |
stats | - the statistics about the sets that are in the catalog |
nextStageID | - the id of the next stage for this job |
Reimplemented from pdb::SimplePhysicalNode.
Definition at line 197 of file SimplePhysicalAggregationNode.cc.
|
overrideprotectedvirtual |
In the case that this aggregation is the output this method is called. It essentially builds the
tupleStageBuilder | - the builder for the tuple set job stage, that contains all the computations in our pipeline so far. |
prevNode | - the previous node we are coming from to analyze this node |
stats | - the statistics about the sets that are in the catalog |
nextStageID | - the id of the next stage for this job |
Reimplemented from pdb::SimplePhysicalNode.
Definition at line 35 of file SimplePhysicalAggregationNode.cc.
|
overrideprotectedvirtual |
In the case that this aggregation has only one consumer this method is called. It essentially builds the
tupleStageBuilder | - the builder for the tuple set job stage, that contains all the computations in our pipeline so far. |
prevNode | - the previous node we are coming from to analyze this node |
stats | - the statistics about the sets that are in the catalog |
nextStageID | - the id of the next stage for this job |
Reimplemented from pdb::SimplePhysicalNode.
Definition at line 110 of file SimplePhysicalAggregationNode.cc.