20 #ifndef PDB_SIMPLEPHYSICALNODE_FACTORY_H
21 #define PDB_SIMPLEPHYSICALNODE_FACTORY_H
58 std::vector<AbstractPhysicalNodePtr>
generateAnalyzerGraph(std::vector<AtomicComputationPtr> sources)
override;
71 std::map<std::string, AbstractPhysicalNodePtr>
nodes;
89 #endif //PDB_SIMPLEPHYSICALNODE_FACTORY_H
SimplePhysicalNodeFactory(const string &jobId, const Handle< ComputePlan > &computePlan, const ConfigurationPtr &conf)
Handle< ComputePlan > computePlan
std::shared_ptr< SimplePhysicalNodeFactory > SimplePhysicalNodeFactoryPtr
shared_ptr< Configuration > ConfigurationPtr
std::shared_ptr< struct AtomicComputation > AtomicComputationPtr
std::shared_ptr< AbstractPhysicalNode > AbstractPhysicalNodePtr
AbstractPhysicalNodePtr createAnalyzerNode(AtomicComputationPtr tcapNode)
void generateConsumerNode(AbstractPhysicalNodePtr source, AtomicComputationPtr node)
std::vector< AbstractPhysicalNodePtr > generateAnalyzerGraph(std::vector< AtomicComputationPtr > sources) override
std::map< std::string, AbstractPhysicalNodePtr > nodes