18 #ifndef PDB_SIMPLEPHYSICALNODE_H
19 #define PDB_SIMPLEPHYSICALNODE_H
195 #endif //PDB_SIMPLEPHYSICALNODE_H
virtual PhysicalOptimizerResultPtr analyzeOutput(TupleSetJobStageBuilderPtr &tupleStageBuilder, SimplePhysicalNodePtr &prevNode, const StatisticsPtr &stats, int nextStageID)
SimplePhysicalNode(string jobId, AtomicComputationPtr node, const Handle< ComputePlan > &computePlan, LogicalPlanPtr logicalPlan, ConfigurationPtr conf)
const AtomicComputationPtr & getNode() const
Handle< ComputePlan > computePlan
std::shared_ptr< Statistics > StatisticsPtr
PhysicalOptimizerResultPtr analyze(const StatisticsPtr &stats, int nextStageID) override
void addConsumer(const AbstractPhysicalNodePtr &consumer) override
double getCost(const StatisticsPtr &stats) override
LogicalPlanPtr logicalPlan
bool isConsuming(Handle< SetIdentifier > &set) override
std::shared_ptr< LogicalPlan > LogicalPlanPtr
std::string getNodeIdentifier() override
virtual PhysicalOptimizerResultPtr analyzeMultipleConsumers(TupleSetJobStageBuilderPtr &ptr, SimplePhysicalNodePtr &prevNode, const StatisticsPtr &stats, int nextStageID)
bool hasConsumers() override
const Handle< SetIdentifier > & getSourceSetIdentifier() const
shared_ptr< Configuration > ConfigurationPtr
std::shared_ptr< struct AtomicComputation > AtomicComputationPtr
std::shared_ptr< SimplePhysicalNode > SimplePhysicalNodePtr
virtual PhysicalOptimizerResultPtr analyzeSingleConsumer(TupleSetJobStageBuilderPtr &tupleStageBuilder, SimplePhysicalNodePtr &prevNode, const StatisticsPtr &stats, int nextStageID)
std::shared_ptr< AbstractPhysicalNode > AbstractPhysicalNodePtr
SimplePhysicalNodePtr getSimpleNodeHandle()
AtomicComputationPtr node
Handle< SetIdentifier > sourceSetIdentifier
std::list< SimplePhysicalNodePtr > activeConsumers
std::shared_ptr< TupleSetJobStageBuilder > TupleSetJobStageBuilderPtr
std::shared_ptr< PhysicalOptimizerResult > PhysicalOptimizerResultPtr