28 vector<AtomicComputationPtr> &pipeComputations,
54 std::vector<AdvancedPhysicalAbstractAlgorithmPtr> ret = { std::make_shared<AdvancedPhysicalPipelineAlgorithm>(
getAdvancedPhysicalNodeHandle(),
Handle< ComputePlan > computePlan
std::shared_ptr< Statistics > StatisticsPtr
AdvancedPhysicalPipelineNodePtr getAdvancedPhysicalNodeHandle()
AdvancedPhysicalAbstractAlgorithmPtr selectedAlgorithm
Handle< SetIdentifier > sourceSetIdentifier
LogicalPlanPtr logicalPlan
AdvancedPhysicalStraightPipe(string &jobId, Handle< ComputePlan > &computePlan, LogicalPlanPtr &logicalPlan, ConfigurationPtr &conf, vector< AtomicComputationPtr > &pipeComputations, size_t id)
std::shared_ptr< LogicalPlan > LogicalPlanPtr
std::vector< AdvancedPhysicalAbstractAlgorithmPtr > getPossibleAlgorithms(const StatisticsPtr &stats) override
AdvancedPhysicalPipelineTypeID getType() override
AdvancedPhysicalAbstractAlgorithmPtr selectOutputAlgorithm() override
shared_ptr< Configuration > ConfigurationPtr
std::list< AbstractPhysicalNodePtr > consumers
AdvancedPhysicalPipelineTypeID
std::shared_ptr< AdvancedPhysicalAbstractAlgorithm > AdvancedPhysicalAbstractAlgorithmPtr