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.
|
This is the complete list of members for pdb::QuerySchedulerServer, including all inherited members.
cleanup() override | pdb::QuerySchedulerServer | virtual |
collectStats() | pdb::QuerySchedulerServer | |
collectStatsForNode(int node, int &counter, PDBBuzzerPtr &callerBuzzer) | pdb::QuerySchedulerServer | protected |
conf | pdb::QuerySchedulerServer | protected |
connection_mutex | pdb::QuerySchedulerServer | protected |
createIntermediateSets(DistributedStorageManagerClient &dsmClient, vector< Handle< SetIdentifier >> &intermediateSets) | pdb::QuerySchedulerServer | protected |
executeComputation(Handle< ExecuteComputation > &request, PDBCommunicatorPtr &sendUsingMe) | pdb::QuerySchedulerServer | protected |
extractPipelineStages(int &jobStageId, vector< Handle< AbstractJobStage >> &jobStages, vector< Handle< SetIdentifier >> &intermediateSets) | pdb::QuerySchedulerServer | protected |
getCommunicatorToNode(int port, std::string &ip) | pdb::QuerySchedulerServer | protected |
getFunctionality() | pdb::ServerFunctionality | inline |
getLogger() | pdb::ServerFunctionality | inline |
getNextJobId() | pdb::QuerySchedulerServer | inline |
getStageToSend(unsigned long index, Handle< TupleSetJobStage > &stage) | pdb::QuerySchedulerServer | protected |
getStageToSend(unsigned long index, Handle< AggregationJobStage > &stage) | pdb::QuerySchedulerServer | protected |
getStageToSend(unsigned long index, Handle< BroadcastJoinBuildHTJobStage > &stage) | pdb::QuerySchedulerServer | protected |
getStageToSend(unsigned long index, Handle< HashPartitionedJoinBuildHTJobStage > &stage) | pdb::QuerySchedulerServer | protected |
getStats() | pdb::QuerySchedulerServer | |
getWorker() | pdb::ServerFunctionality | inline |
initialize() | pdb::QuerySchedulerServer | protected |
initializeForPseudoClusterMode() | pdb::QuerySchedulerServer | protected |
initializeForServerMode() | pdb::QuerySchedulerServer | protected |
interGlobalSets | pdb::QuerySchedulerServer | protected |
jobId | pdb::QuerySchedulerServer | protected |
logger | pdb::QuerySchedulerServer | protected |
partitionToCoreRatio | pdb::QuerySchedulerServer | protected |
physicalOptimizerPtr | pdb::QuerySchedulerServer | protected |
port | pdb::QuerySchedulerServer | protected |
prepareAndScheduleStage(Handle< AbstractJobStage > &stage, unsigned long node, int &counter, PDBBuzzerPtr &callerBuzzer) | pdb::QuerySchedulerServer | protected |
pseudoClusterMode | pdb::QuerySchedulerServer | protected |
QuerySchedulerServer(PDBLoggerPtr logger, ConfigurationPtr conf, std::shared_ptr< StatisticsDB > statisticsDB, bool pseudoClusterMode=false, double partitionToCoreRatio=0.75) | pdb::QuerySchedulerServer | |
QuerySchedulerServer(int port, PDBLoggerPtr logger, ConfigurationPtr conf, std::shared_ptr< StatisticsDB > statisticsDB, bool pseudoClusterMode=false, double partitionToCoreRatio=0.75) | pdb::QuerySchedulerServer | |
recordServer(PDBServer &recordMe) | pdb::ServerFunctionality | inline |
registerHandlers(PDBServer &forMe) override | pdb::QuerySchedulerServer | virtual |
registerReplica(Handle< RegisterReplica > &request, PDBCommunicatorPtr &sendUsingMe) | pdb::QuerySchedulerServer | protected |
removeIntermediateSets(DistributedStorageManagerClient &dsmClient) | pdb::QuerySchedulerServer | protected |
removeUnusedIntermediateSets(DistributedStorageManagerClient &dsmClient, vector< Handle< SetIdentifier >> &intermediateSets) | pdb::QuerySchedulerServer | protected |
requestStatistics(PDBCommunicatorPtr &communicator, bool &success, string &errMsg) const | pdb::QuerySchedulerServer | protected |
scheduleStage(unsigned long node, Handle< T > &stage, PDBCommunicatorPtr communicator) | pdb::QuerySchedulerServer | protected |
scheduleStages(std::vector< Handle< AbstractJobStage >> &stagesToSchedule, std::shared_ptr< ShuffleInfo > shuffleInfo) | pdb::QuerySchedulerServer | protected |
seqId | pdb::QuerySchedulerServer | protected |
shuffleInfo | pdb::QuerySchedulerServer | protected |
standardResources | pdb::QuerySchedulerServer | protected |
statisticsDB | pdb::QuerySchedulerServer | protected |
statsForOptimization | pdb::QuerySchedulerServer | protected |
updateStats(Handle< SetIdentifier > setToUpdateStats) | pdb::QuerySchedulerServer | protected |
~QuerySchedulerServer() | pdb::QuerySchedulerServer |