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.
|
#include <AdvancedPhysicalPipelineAlgorithm.h>
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< AtomicComputationPtr > | pipelineComputations |
unordered_map< std::string, std::string > | probingHashSets |
LogicalPlanPtr | logicalPlan |
Handle< ComputePlan > | computePlan |
ConfigurationPtr | conf |
Handle< SetIdentifier > | sink |
Handle< SetIdentifier > | source |
bool | isProbing |
bool | isOutput |
Definition at line 26 of file AdvancedPhysicalPipelineAlgorithm.h.
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.
|
overridevirtual |
Generates the stages for this algorithm
Implements pdb::AdvancedPhysicalAbstractAlgorithm.
Definition at line 42 of file AdvancedPhysicalPipelineAlgorithm.cc.
|
overridevirtual |
Returns the type of the algorithm
Implements pdb::AdvancedPhysicalAbstractAlgorithm.
Definition at line 157 of file AdvancedPhysicalPipelineAlgorithm.cc.