A platform for high-performance distributed tool and library development written in C++. It can be deployed in two different cluster modes: standalone or distributed. API for v0.5.0, released on June 13, 2018.
 All Classes Namespaces Files Functions Variables Typedefs Enumerations Enumerator Friends Macros
pdb::AdvancedPhysicalPipelineAlgorithm Class Reference

#include <AdvancedPhysicalPipelineAlgorithm.h>

+ Inheritance diagram for pdb::AdvancedPhysicalPipelineAlgorithm:
+ Collaboration diagram for pdb::AdvancedPhysicalPipelineAlgorithm:

Public Member Functions

 AdvancedPhysicalPipelineAlgorithm (const AdvancedPhysicalPipelineNodePtr &handle, const std::string &jobID, bool isProbing, bool isOutput, const Handle< SetIdentifier > &source, const Handle< ComputePlan > &computePlan, const LogicalPlanPtr &logicalPlan, const ConfigurationPtr &conf)
 
PhysicalOptimizerResultPtr generate (int nextStageID, const StatisticsPtr &stats) override
 
AdvancedPhysicalAbstractAlgorithmTypeID getType () override
 
- Public Member Functions inherited from pdb::AdvancedPhysicalAbstractAlgorithm
 AdvancedPhysicalAbstractAlgorithm (const AdvancedPhysicalPipelineNodePtr &handle, const std::string &jobID, bool isProbing, bool isOutput, Handle< SetIdentifier > source, Handle< ComputePlan > computePlan, const LogicalPlanPtr &logicalPlan, const ConfigurationPtr &conf)
 
virtual PhysicalOptimizerResultPtr generatePipelined (int nextStageID, const StatisticsPtr &stats, std::vector< AdvancedPhysicalPipelineNodePtr > &pipesToPipeline)
 

Additional Inherited Members

- Protected Member Functions inherited from pdb::AdvancedPhysicalAbstractAlgorithm
virtual DataStatistics approximateResultSize (const StatisticsPtr &stats)
 
void updateConsumers (const Handle< SetIdentifier > &sink, DataStatistics approxSize, const StatisticsPtr &stats)
 
void includeHashComputation ()
 
void extractAtomicComputations ()
 
void extractHashSetsToProbe ()
 
- Protected Attributes inherited from pdb::AdvancedPhysicalAbstractAlgorithm
std::list
< AdvancedPhysicalPipelineNodePtr
pipeline
 
std::string jobID
 
list< AtomicComputationPtrpipelineComputations
 
unordered_map< std::string,
std::string > 
probingHashSets
 
LogicalPlanPtr logicalPlan
 
Handle< ComputePlancomputePlan
 
ConfigurationPtr conf
 
Handle< SetIdentifiersink
 
Handle< SetIdentifiersource
 
bool isProbing
 
bool isOutput
 

Detailed Description

Definition at line 26 of file AdvancedPhysicalPipelineAlgorithm.h.

Constructor & Destructor Documentation

pdb::AdvancedPhysicalPipelineAlgorithm::AdvancedPhysicalPipelineAlgorithm ( const AdvancedPhysicalPipelineNodePtr handle,
const std::string &  jobID,
bool  isProbing,
bool  isOutput,
const Handle< SetIdentifier > &  source,
const Handle< ComputePlan > &  computePlan,
const LogicalPlanPtr logicalPlan,
const ConfigurationPtr conf 
)

Definition at line 25 of file AdvancedPhysicalPipelineAlgorithm.cc.

Member Function Documentation

PhysicalOptimizerResultPtr pdb::AdvancedPhysicalPipelineAlgorithm::generate ( int  nextStageID,
const StatisticsPtr stats 
)
overridevirtual

Generates the stages for this algorithm

Returns

Implements pdb::AdvancedPhysicalAbstractAlgorithm.

Definition at line 42 of file AdvancedPhysicalPipelineAlgorithm.cc.

+ Here is the call graph for this function:

AdvancedPhysicalAbstractAlgorithmTypeID pdb::AdvancedPhysicalPipelineAlgorithm::getType ( )
overridevirtual

Returns the type of the algorithm

Returns
the type id

Implements pdb::AdvancedPhysicalAbstractAlgorithm.

Definition at line 157 of file AdvancedPhysicalPipelineAlgorithm.cc.


The documentation for this class was generated from the following files: