#include <gpudb/utils/GPUdbMultiHeadIOUtils.h>
Public Types | |
| typedef std::vector< gpudb::GenericRecord > | recordVector_T |
Public Member Functions | |
| WorkerQueue (const std::string &url) | |
| WorkerQueue (const std::string &url, size_t capacity) | |
| ~WorkerQueue () | |
| void | clear () |
| Clear queue without sending. | |
| const gpudb::HttpUrl & | get_url () const |
| Returns the URL in string format for this worker. | |
| void | flush (recordVector_T &flushed_records) |
| Returns the current queue and creates a new internal queue. | |
| bool | insert (const gpudb::GenericRecord &record, const RecordKey &key, recordVector_T &flushed_records) |
| Inserts a record into the queue. | |
Detailed Description
Definition at line 333 of file GPUdbMultiHeadIOUtils.h.
Member Typedef Documentation
◆ recordVector_T
| typedef std::vector<gpudb::GenericRecord> gpudb::WorkerQueue::recordVector_T |
Definition at line 338 of file GPUdbMultiHeadIOUtils.h.
Constructor & Destructor Documentation
◆ WorkerQueue() [1/2]
| gpudb::WorkerQueue::WorkerQueue | ( | const std::string & | url | ) |
◆ WorkerQueue() [2/2]
| gpudb::WorkerQueue::WorkerQueue | ( | const std::string & | url, |
| size_t | capacity ) |
◆ ~WorkerQueue()
| gpudb::WorkerQueue::~WorkerQueue | ( | ) |
Member Function Documentation
◆ clear()
| void gpudb::WorkerQueue::clear | ( | ) |
Clear queue without sending.
◆ flush()
| void gpudb::WorkerQueue::flush | ( | recordVector_T & | flushed_records | ) |
Returns the current queue and creates a new internal queue.
◆ get_url()
| inline |
Returns the URL in string format for this worker.
Definition at line 363 of file GPUdbMultiHeadIOUtils.h.
◆ insert()
| bool gpudb::WorkerQueue::insert | ( | const gpudb::GenericRecord & | record, |
| const RecordKey & | key, | ||
| recordVector_T & | flushed_records ) |
Inserts a record into the queue.
The documentation for this class was generated from the following file:
- gpudb/utils/GPUdbMultiHeadIOUtils.h