18 #ifndef PDB_SIMPLEPHYSICALJOINNODE_H
19 #define PDB_SIMPLEPHYSICALJOINNODE_H
50 int nextStageID)
override;
72 int nextStageID)
override;
101 #endif //PDB_SIMPLEPHYSICALJOINNODE_H
PhysicalOptimizerResultPtr analyzeSingleConsumer(TupleSetJobStageBuilderPtr &tupleStageBuilder, SimplePhysicalNodePtr &prevNode, const StatisticsPtr &stats, int nextStageID) override
Handle< ComputePlan > computePlan
std::shared_ptr< Statistics > StatisticsPtr
LogicalPlanPtr logicalPlan
std::shared_ptr< LogicalPlan > LogicalPlanPtr
PhysicalOptimizerResultPtr analyzeOutput(TupleSetJobStageBuilderPtr &ptr, SimplePhysicalNodePtr &prevNode, const StatisticsPtr &stats, int nextStageID) override
const double BROADCAST_JOIN_COST_THRESHOLD
shared_ptr< Configuration > ConfigurationPtr
std::shared_ptr< struct AtomicComputation > AtomicComputationPtr
std::shared_ptr< SimplePhysicalNode > SimplePhysicalNodePtr
SimplePhysicalJoinNode(string jobId, AtomicComputationPtr node, const Handle< ComputePlan > &computePlan, LogicalPlanPtr logicalPlan, ConfigurationPtr conf)
AtomicComputationPtr node
std::shared_ptr< TupleSetJobStageBuilder > TupleSetJobStageBuilderPtr
std::shared_ptr< PhysicalOptimizerResult > PhysicalOptimizerResultPtr