![]() |
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 <AdvancedPhysicalShuffledHashsetPipelineAlgorithm.h>
Inheritance diagram for pdb::AdvancedPhysicalShuffledHashsetPipelineAlgorithm:
Collaboration diagram for pdb::AdvancedPhysicalShuffledHashsetPipelineAlgorithm:Public Member Functions | |
| AdvancedPhysicalShuffledHashsetPipelineAlgorithm (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 AdvancedPhysicalShuffledHashsetPipelineAlgorithm.h.
| AdvancedPhysicalShuffledHashsetPipelineAlgorithm::AdvancedPhysicalShuffledHashsetPipelineAlgorithm | ( | 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 | ||
| ) |
| handle | |
| nextStageID | |
| pipeComputations | |
| logicalPlan | |
| conf |
Definition at line 25 of file AdvancedPhysicalShuffledHashsetPipelineAlgorithm.cc.
|
overridevirtual |
Generates the stages for this algorithm
Implements pdb::AdvancedPhysicalAbstractAlgorithm.
Definition at line 42 of file AdvancedPhysicalShuffledHashsetPipelineAlgorithm.cc.
Here is the call graph for this function:
|
overridevirtual |
Returns the type of the algorithm
Implements pdb::AdvancedPhysicalAbstractAlgorithm.
Definition at line 161 of file AdvancedPhysicalShuffledHashsetPipelineAlgorithm.cc.