19 #ifndef PDB_ADVANCEDPHYSICALNODEFACTORY_H
20 #define PDB_ADVANCEDPHYSICALNODEFACTORY_H
56 void setConsumers(shared_ptr<AdvancedPhysicalAbstractPipe> node);
76 auto nodeHandle = node->getAdvancedPhysicalNodeHandle();
82 if(nodeHandle->isSource()) {
89 std::cout << c->getOutputName() << std::endl;
92 std::cout <<
"-----------------------------------------" << std::endl;
96 startsWith[currentPipe.front()->getOutputName()] = nodeHandle;
141 std::map<std::string, AdvancedPhysicalPipelineNodePtr>
startsWith;
151 std::vector<AdvancedPhysicalPipelineNodePtr>
sources;
158 #endif //PDB_ADVANCEDPHYSICALNODEFACTORY_H
std::vector< AbstractPhysicalNodePtr > physicalSourceNodes
std::map< std::string, std::vector< std::string > > consumedBy
Handle< ComputePlan > computePlan
AdvancedPhysicalNodeFactory(const string &jobId, const Handle< ComputePlan > &computePlan, const ConfigurationPtr &conf)
std::map< std::string, AdvancedPhysicalPipelineNodePtr > physicalNodes
std::map< std::string, AdvancedPhysicalPipelineNodePtr > startsWith
std::set< AtomicComputationPtr > visitedNodes
void transverseTCAPGraph(AtomicComputationPtr curNode)
std::vector< AtomicComputationPtr > currentPipe
std::vector< AdvancedPhysicalPipelineNodePtr > sources
void setConsumers(shared_ptr< AdvancedPhysicalAbstractPipe > node)
void createPhysicalPipeline()
vector< AbstractPhysicalNodePtr > generateAnalyzerGraph(std::vector< AtomicComputationPtr > sources) override
shared_ptr< Configuration > ConfigurationPtr
std::shared_ptr< struct AtomicComputation > AtomicComputationPtr
LogicalPlanPtr logicalPlan