18 #ifndef PDB_SIMPLEPHYSICALAGGREGATIONNODE_H
19 #define PDB_SIMPLEPHYSICALAGGREGATIONNODE_H
54 int nextStageID)
override;
71 int nextStageID)
override;
88 int nextStageID)
override;
95 #endif //PDB_SIMPLEPHYSICALAGGREGATIONNODE_H
Handle< ComputePlan > computePlan
std::shared_ptr< Statistics > StatisticsPtr
PhysicalOptimizerResultPtr analyzeOutput(TupleSetJobStageBuilderPtr &tupleStageBuilder, SimplePhysicalNodePtr &prevNode, const StatisticsPtr &stats, int nextStageID) override
LogicalPlanPtr logicalPlan
std::shared_ptr< LogicalPlan > LogicalPlanPtr
PhysicalOptimizerResultPtr analyzeMultipleConsumers(TupleSetJobStageBuilderPtr &tupleStageBuilder, SimplePhysicalNodePtr &prevNode, const StatisticsPtr &stats, int nextStageID) override
SimplePhysicalAggregationNode(string jobId, AtomicComputationPtr node, const Handle< ComputePlan > &computePlan, LogicalPlanPtr logicalPlan, ConfigurationPtr conf)
shared_ptr< Configuration > ConfigurationPtr
std::shared_ptr< struct AtomicComputation > AtomicComputationPtr
std::shared_ptr< SimplePhysicalNode > SimplePhysicalNodePtr
AtomicComputationPtr node
PhysicalOptimizerResultPtr analyzeSingleConsumer(TupleSetJobStageBuilderPtr &tupleStageBuilder, SimplePhysicalNodePtr &prevNode, const StatisticsPtr &stats, int nextStageID) override
std::shared_ptr< TupleSetJobStageBuilder > TupleSetJobStageBuilderPtr
std::shared_ptr< PhysicalOptimizerResult > PhysicalOptimizerResultPtr