 |
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.
|
|
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::PipelineStage, including all inherited members.
| batchSize | pdb::PipelineStage | private |
| conf | pdb::PipelineStage | private |
| createProxy(int i, pthread_mutex_t connection_mutex, std::string &errMsg) | pdb::PipelineStage | |
| executePipelineWork(int i, SetSpecifierPtr outputSet, std::vector< PageCircularBufferIteratorPtr > &iterators, PartitionedHashSetPtr hashSet, DataProxyPtr proxy, std::vector< PageCircularBufferPtr > &sinkBuffers, HermesExecutionServer *server, std::string &errMsg) | pdb::PipelineStage | |
| feedSharedBuffers(HermesExecutionServer *server, std::vector< PageCircularBufferPtr > &sourceBuffers, int numPartitions, int &counter, PDBBuzzerPtr tempBuzzer, bool &success, std::string &errMsg) | pdb::PipelineStage | |
| getBackendCircularBufferSize(bool &success, std::string &errMsg) | pdb::PipelineStage | |
| getJobStage() | pdb::PipelineStage | |
| getNumThreads() | pdb::PipelineStage | |
| getUserSetIterators(HermesExecutionServer *server, int numThreads, bool &success, std::string &errMsg) | pdb::PipelineStage | |
| id | pdb::PipelineStage | private |
| jobStage | pdb::PipelineStage | private |
| logger | pdb::PipelineStage | private |
| nodeId | pdb::PipelineStage | private |
| nodeIds | pdb::PipelineStage | private |
| numThreads | pdb::PipelineStage | private |
| PipelineStage(Handle< TupleSetJobStage > stage, SharedMemPtr shm, PDBLoggerPtr logger, ConfigurationPtr conf, NodeID nodeId, size_t batchSize, int numThreads) | pdb::PipelineStage | |
| runPipeline(HermesExecutionServer *server, std::vector< PageCircularBufferPtr > combinerBuffers, SetSpecifierPtr outputSet) | pdb::PipelineStage | |
| runPipeline(HermesExecutionServer *server) | pdb::PipelineStage | |
| runPipelineWithBroadcastSink(HermesExecutionServer *server) | pdb::PipelineStage | |
| runPipelineWithHashPartitionSink(HermesExecutionServer *server) | pdb::PipelineStage | |
| runPipelineWithShuffleSink(HermesExecutionServer *server) | pdb::PipelineStage | |
| sendData(PDBCommunicatorPtr conn, void *bytes, size_t size, std::string databaseName, std::string setName, std::string &errMsg) | pdb::PipelineStage | |
| shm | pdb::PipelineStage | private |
| storeCompressedShuffleData(char *bytes, size_t numBytes, std::string databaseName, std::string setName, std::string address, int port, std::string &errMsg) | pdb::PipelineStage | |
| storeShuffleData(Handle< Vector< Handle< Object >>> data, std::string databaseName, std::string setName, std::string address, int port, bool whetherToPersiste, std::string &errMsg) | pdb::PipelineStage | |
| ~PipelineStage() | pdb::PipelineStage |
1.8.6 
