GPUdb C++ API
Version 6.0.1.0
|
#include <gpudb/GPUdbIngestor.hpp>
Public Member Functions | |
WorkerQueue (std::string url, size_t capacity, bool has_primary_key, bool update_on_existing_pk) | |
std::vector< T > & | flush () |
Returns the current queue and creates a new internal queue. More... | |
std::vector< T > & | insert (T record, RecordKey key) |
Inserts a record into the queue. More... | |
Definition at line 115 of file GPUdbIngestor.hpp.
gpudb::WorkerQueue< T >::WorkerQueue | ( | std::string | url, |
size_t | capacity, | ||
bool | has_primary_key, | ||
bool | update_on_existing_pk | ||
) |
std::vector<T>& gpudb::WorkerQueue< T >::flush | ( | ) |
Returns the current queue and creates a new internal queue.
std::vector<T>& gpudb::WorkerQueue< T >::insert | ( | T | record, |
RecordKey | key | ||
) |
Inserts a record into the queue.