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::QuerySchedulerServer Member List

This is the complete list of members for pdb::QuerySchedulerServer, including all inherited members.

cleanup() overridepdb::QuerySchedulerServervirtual
collectStats()pdb::QuerySchedulerServer
collectStatsForNode(int node, int &counter, PDBBuzzerPtr &callerBuzzer)pdb::QuerySchedulerServerprotected
confpdb::QuerySchedulerServerprotected
connection_mutexpdb::QuerySchedulerServerprotected
createIntermediateSets(DistributedStorageManagerClient &dsmClient, vector< Handle< SetIdentifier >> &intermediateSets)pdb::QuerySchedulerServerprotected
executeComputation(Handle< ExecuteComputation > &request, PDBCommunicatorPtr &sendUsingMe)pdb::QuerySchedulerServerprotected
extractPipelineStages(int &jobStageId, vector< Handle< AbstractJobStage >> &jobStages, vector< Handle< SetIdentifier >> &intermediateSets)pdb::QuerySchedulerServerprotected
getCommunicatorToNode(int port, std::string &ip)pdb::QuerySchedulerServerprotected
getFunctionality()pdb::ServerFunctionalityinline
getLogger()pdb::ServerFunctionalityinline
getNextJobId()pdb::QuerySchedulerServerinline
getStageToSend(unsigned long index, Handle< TupleSetJobStage > &stage)pdb::QuerySchedulerServerprotected
getStageToSend(unsigned long index, Handle< AggregationJobStage > &stage)pdb::QuerySchedulerServerprotected
getStageToSend(unsigned long index, Handle< BroadcastJoinBuildHTJobStage > &stage)pdb::QuerySchedulerServerprotected
getStageToSend(unsigned long index, Handle< HashPartitionedJoinBuildHTJobStage > &stage)pdb::QuerySchedulerServerprotected
getStats()pdb::QuerySchedulerServer
getWorker()pdb::ServerFunctionalityinline
initialize()pdb::QuerySchedulerServerprotected
initializeForPseudoClusterMode()pdb::QuerySchedulerServerprotected
initializeForServerMode()pdb::QuerySchedulerServerprotected
interGlobalSetspdb::QuerySchedulerServerprotected
jobIdpdb::QuerySchedulerServerprotected
loggerpdb::QuerySchedulerServerprotected
partitionToCoreRatiopdb::QuerySchedulerServerprotected
physicalOptimizerPtrpdb::QuerySchedulerServerprotected
portpdb::QuerySchedulerServerprotected
prepareAndScheduleStage(Handle< AbstractJobStage > &stage, unsigned long node, int &counter, PDBBuzzerPtr &callerBuzzer)pdb::QuerySchedulerServerprotected
pseudoClusterModepdb::QuerySchedulerServerprotected
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::ServerFunctionalityinline
registerHandlers(PDBServer &forMe) overridepdb::QuerySchedulerServervirtual
registerReplica(Handle< RegisterReplica > &request, PDBCommunicatorPtr &sendUsingMe)pdb::QuerySchedulerServerprotected
removeIntermediateSets(DistributedStorageManagerClient &dsmClient)pdb::QuerySchedulerServerprotected
removeUnusedIntermediateSets(DistributedStorageManagerClient &dsmClient, vector< Handle< SetIdentifier >> &intermediateSets)pdb::QuerySchedulerServerprotected
requestStatistics(PDBCommunicatorPtr &communicator, bool &success, string &errMsg) const pdb::QuerySchedulerServerprotected
scheduleStage(unsigned long node, Handle< T > &stage, PDBCommunicatorPtr communicator)pdb::QuerySchedulerServerprotected
scheduleStages(std::vector< Handle< AbstractJobStage >> &stagesToSchedule, std::shared_ptr< ShuffleInfo > shuffleInfo)pdb::QuerySchedulerServerprotected
seqIdpdb::QuerySchedulerServerprotected
shuffleInfopdb::QuerySchedulerServerprotected
standardResourcespdb::QuerySchedulerServerprotected
statisticsDBpdb::QuerySchedulerServerprotected
statsForOptimizationpdb::QuerySchedulerServerprotected
updateStats(Handle< SetIdentifier > setToUpdateStats)pdb::QuerySchedulerServerprotected
~QuerySchedulerServer()pdb::QuerySchedulerServer