GPUdb C++ API
Version 7.0.19.0
|
#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, bool has_primary_key, bool update_on_existing_pk) | |
~WorkerQueue () | |
const gpudb::HttpUrl & | get_url () const |
Returns the URL in string format for this worker. More... | |
void | flush (recordVector_T &flushed_records) |
Returns the current queue and creates a new internal queue. More... | |
bool | insert (const gpudb::GenericRecord &record, const RecordKey &key, recordVector_T &flushed_records) |
Inserts a record into the queue. More... | |
Definition at line 314 of file GPUdbMultiHeadIOUtils.h.
typedef std::vector<gpudb::GenericRecord> gpudb::WorkerQueue::recordVector_T |
Definition at line 319 of file GPUdbMultiHeadIOUtils.h.
gpudb::WorkerQueue::WorkerQueue | ( | const std::string & | url | ) |
gpudb::WorkerQueue::WorkerQueue | ( | const std::string & | url, |
size_t | capacity, | ||
bool | has_primary_key, | ||
bool | update_on_existing_pk | ||
) |
gpudb::WorkerQueue::~WorkerQueue | ( | ) |
void gpudb::WorkerQueue::flush | ( | recordVector_T & | flushed_records | ) |
Returns the current queue and creates a new internal queue.
|
inline |
Returns the URL in string format for this worker.
Definition at line 349 of file GPUdbMultiHeadIOUtils.h.
bool gpudb::WorkerQueue::insert | ( | const gpudb::GenericRecord & | record, |
const RecordKey & | key, | ||
recordVector_T & | flushed_records | ||
) |
Inserts a record into the queue.