|
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.