gpudb::WorkerQueue Class Reference

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

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()

const gpudb::HttpUrl& gpudb::WorkerQueue::get_url ( ) const

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