![]() |
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 |