A TableMutator that can be shared from multiple threads and incidentally has an option to do periodic flushes. More...

#include <TableMutatorShared.h>

Inheritance diagram for Hypertable::TableMutatorShared:

Collaboration diagram for Hypertable::TableMutatorShared:

Public Member Functions
	TableMutatorShared (PropertiesPtr &props, Comm comm, Table table, RangeLocatorPtr &range_locator, ApplicationQueueInterfacePtr &app_queue, uint32_t timeout_ms, uint32_t flush_interval_ms, uint32_t flags=0)

virtual	~TableMutatorShared ()

virtual void	set (const KeySpec &key, const void *value, uint32_t value_len)

virtual void	set_delete (const KeySpec &key)

virtual void	set_cells (const Cells &cells)

virtual void	flush ()

virtual bool	retry (uint32_t timeout_ms=0)

virtual uint64_t	memory_used ()

virtual uint64_t	get_resend_count ()

virtual void	get_failed (FailedMutations &failed_mutations)

virtual bool	need_retry ()

uint32_t	flush_interval ()

void	interval_flush ()
	Flush if necessary considering the flush interval. More...

Public Member Functions inherited from Hypertable::TableMutator
	TableMutator (PropertiesPtr &props, Comm comm, Table table, RangeLocatorPtr &range_locator, uint32_t timeout_ms, uint32_t flags=0)
	Constructs the TableMutator object. More...

virtual	~TableMutator ()
	Destructor for TableMutator object Make sure buffers are flushed and unsynced rangeservers get synced. More...

void	set (const KeySpec &key, const char *value)
	Convenient helper for null-terminated values. More...

void	set (const KeySpec &key, const std::string &value)
	Convenient helper for std::string values. More...

uint64_t	get_resend_count ()
	There are certain circumstances when mutations get flushed to the wrong range server due to stale range location information. More...

std::ostream &	show_failed (const Exception &, std::ostream &=std::cout)
	Show failed mutations. More...

void	update_ok ()

void	update_error (int error, FailedMutations &failures)

int32_t	get_last_error ()

Public Member Functions inherited from Hypertable::ClientObject
virtual	~ClientObject ()
	Destructor. More...

Private Types
typedef TableMutator	Parent

Private Attributes
std::recursive_mutex	m_mutex

uint32_t	m_flush_interval

std::chrono::steady_clock::time_point	m_last_flush_ts

std::shared_ptr < TableMutatorIntervalHandler >	m_tick_handler

Additional Inherited Members
Public Types inherited from Hypertable::TableMutator
enum	{ FLAG_NO_LOG_SYNC = Table::MUTATOR_FLAG_NO_LOG_SYNC, FLAG_NO_LOG = Table::MUTATOR_FLAG_NO_LOG }

Detailed Description

A TableMutator that can be shared from multiple threads and incidentally has an option to do periodic flushes.

For best throughput use the vanilla TableMutator

Definition at line 38 of file TableMutatorShared.h.

Member Typedef Documentation

typedef TableMutator Hypertable::TableMutatorShared::Parent

private

Definition at line 39 of file TableMutatorShared.h.

Constructor & Destructor Documentation

TableMutatorShared::TableMutatorShared	(	PropertiesPtr &	props,
		Comm *	comm,
		Table *	table,
		RangeLocatorPtr &	range_locator,
		ApplicationQueueInterfacePtr &	app_queue,
		uint32_t	timeout_ms,
		uint32_t	flush_interval_ms,
		uint32_t	flags = `0`
	)

Parameters

props	smart pointer to the Comm layer
comm	pointer to the Comm layer
table	pointer to the table object
range_locator	smart pointer to the range locator
app_queue	pointer to the application queue
timeout_ms	maximum time in milliseconds to allow methods to execute before throwing an exception
flush_interval_ms	period in milliseconds to flush
flags	rangeserver client update command flags