Inheritance diagram for Hypertable::ThriftBroker::ServerHandler:

Collaboration diagram for Hypertable::ThriftBroker::ServerHandler:

Classes
struct	Statistics

Public Member Functions
	ServerHandler (const String &remote_peer, Context &c)

virtual	~ServerHandler ()

const String &	remote_peer () const

void	log_slow_query (const char func_name, std::chrono::fast_clock::time_point start_time, std::chrono::fast_clock::time_point end_time, int64_t latency_ms, ProfileDataScanner &profile_data, Hypertable::Namespace ns, const string &hql)

void	log_slow_query_scanspec (const char func_name, std::chrono::fast_clock::time_point start_time, std::chrono::fast_clock::time_point end_time, int64_t latency_ms, ProfileDataScanner &profile_data, Hypertable::Namespace ns, const string &table, Hypertable::ScanSpec &ss)

void	hql_exec (HqlResult &result, const ThriftGen::Namespace ns, const String &hql, bool noflush, bool unbuffered) override

void	hql_query (HqlResult &result, const ThriftGen::Namespace ns, const String &hql) override

void	hql_exec2 (HqlResult2 &result, const ThriftGen::Namespace ns, const String &hql, bool noflush, bool unbuffered) override

void	hql_exec_as_arrays (HqlResultAsArrays &result, const ThriftGen::Namespace ns, const String &hql, bool noflush, bool unbuffered) override

void	hql_query2 (HqlResult2 &result, const ThriftGen::Namespace ns, const String &hql) override

void	hql_query_as_arrays (HqlResultAsArrays &result, const ThriftGen::Namespace ns, const String &hql) override

void	namespace_create (const String &ns) override

void	create_namespace (const String &ns) override

void	table_create (const ThriftGen::Namespace ns, const String &table, const ThriftGen::Schema &schema) override

void	table_alter (const ThriftGen::Namespace ns, const String &table, const ThriftGen::Schema &schema) override

Scanner	scanner_open (const ThriftGen::Namespace ns, const String &table, const ThriftGen::ScanSpec &ss) override

Scanner	open_scanner (const ThriftGen::Namespace ns, const String &table, const ThriftGen::ScanSpec &ss) override

ScannerAsync	async_scanner_open (const ThriftGen::Namespace ns, const String &table, const ThriftGen::Future ff, const ThriftGen::ScanSpec &ss) override

ScannerAsync	open_scanner_async (const ThriftGen::Namespace ns, const String &table, const ThriftGen::Future ff, const ThriftGen::ScanSpec &ss) override

void	namespace_close (const ThriftGen::Namespace ns) override

void	close_namespace (const ThriftGen::Namespace ns) override

void	refresh_table (const ThriftGen::Namespace ns, const String &table_name) override

void	scanner_close (const Scanner id) override

void	close_scanner (const Scanner scanner) override

void	async_scanner_cancel (const ScannerAsync scanner) override

void	cancel_scanner_async (const ScannerAsync scanner) override

void	async_scanner_close (const ScannerAsync scanner_async) override

void	close_scanner_async (const ScannerAsync scanner_async) override

void	scanner_get_cells (ThriftCells &result, const Scanner scanner_id) override

void	next_cells (ThriftCells &result, const Scanner scanner_id) override

void	scanner_get_cells_as_arrays (ThriftCellsAsArrays &result, const Scanner scanner_id) override

void	next_cells_as_arrays (ThriftCellsAsArrays &result, const Scanner scanner_id) override

void	scanner_get_cells_serialized (CellsSerialized &result, const Scanner scanner_id) override

void	next_cells_serialized (CellsSerialized &result, const Scanner scanner_id) override

void	scanner_get_row (ThriftCells &result, const Scanner scanner_id) override

void	next_row (ThriftCells &result, const Scanner scanner_id) override

void	scanner_get_row_as_arrays (ThriftCellsAsArrays &result, const Scanner scanner_id) override

void	next_row_as_arrays (ThriftCellsAsArrays &result, const Scanner scanner_id) override

void	scanner_get_row_serialized (CellsSerialized &result, const Scanner scanner_id) override

void	next_row_serialized (CellsSerialized &result, const Scanner scanner_id) override

void	get_row (ThriftCells &result, const ThriftGen::Namespace ns, const String &table, const String &row) override

void	get_row_as_arrays (ThriftCellsAsArrays &result, const ThriftGen::Namespace ns, const String &table, const String &row) override

void	get_row_serialized (CellsSerialized &result, const ThriftGen::Namespace ns, const std::string &table, const std::string &row) override

void	get_cell (Value &result, const ThriftGen::Namespace ns, const String &table, const String &row, const String &column) override

void	get_cells (ThriftCells &result, const ThriftGen::Namespace ns, const String &table, const ThriftGen::ScanSpec &ss) override

void	get_cells_as_arrays (ThriftCellsAsArrays &result, const ThriftGen::Namespace ns, const String &table, const ThriftGen::ScanSpec &ss) override

void	get_cells_serialized (CellsSerialized &result, const ThriftGen::Namespace ns, const String &table, const ThriftGen::ScanSpec &ss) override

void	shared_mutator_set_cells (const ThriftGen::Namespace ns, const String &table, const ThriftGen::MutateSpec &mutate_spec, const ThriftCells &cells) override

void	offer_cells (const ThriftGen::Namespace ns, const String &table, const ThriftGen::MutateSpec &mutate_spec, const ThriftCells &cells) override

void	shared_mutator_set_cell (const ThriftGen::Namespace ns, const String &table, const ThriftGen::MutateSpec &mutate_spec, const ThriftGen::Cell &cell) override

void	offer_cell (const ThriftGen::Namespace ns, const String &table, const ThriftGen::MutateSpec &mutate_spec, const ThriftGen::Cell &cell) override

void	shared_mutator_set_cells_as_arrays (const ThriftGen::Namespace ns, const String &table, const ThriftGen::MutateSpec &mutate_spec, const ThriftCellsAsArrays &cells) override

void	offer_cells_as_arrays (const ThriftGen::Namespace ns, const String &table, const ThriftGen::MutateSpec &mutate_spec, const ThriftCellsAsArrays &cells) override

void	shared_mutator_set_cell_as_array (const ThriftGen::Namespace ns, const String &table, const ThriftGen::MutateSpec &mutate_spec, const CellAsArray &cell) override

void	offer_cell_as_array (const ThriftGen::Namespace ns, const String &table, const ThriftGen::MutateSpec &mutate_spec, const CellAsArray &cell) override

ThriftGen::Future	future_open (int capacity) override

ThriftGen::Future	open_future (int capacity) override

void	future_get_result (ThriftGen::Result &tresult, ThriftGen::Future ff, int timeout_millis) override

void	get_future_result (ThriftGen::Result &tresult, ThriftGen::Future ff, int timeout_millis) override

void	future_get_result_as_arrays (ThriftGen::ResultAsArrays &tresult, ThriftGen::Future ff, int timeout_millis) override

void	get_future_result_as_arrays (ThriftGen::ResultAsArrays &tresult, ThriftGen::Future ff, int timeout_millis) override

void	future_get_result_serialized (ThriftGen::ResultSerialized &tresult, ThriftGen::Future ff, int timeout_millis) override

void	get_future_result_serialized (ThriftGen::ResultSerialized &tresult, ThriftGen::Future ff, int timeout_millis) override

void	future_cancel (ThriftGen::Future ff) override

void	cancel_future (ThriftGen::Future ff) override

bool	future_is_empty (ThriftGen::Future ff) override

bool	future_is_full (ThriftGen::Future ff) override

bool	future_is_cancelled (ThriftGen::Future ff) override

bool	future_has_outstanding (ThriftGen::Future ff) override

void	future_close (const ThriftGen::Future ff) override

void	close_future (const ThriftGen::Future ff) override

ThriftGen::Namespace	namespace_open (const String &ns) override

ThriftGen::Namespace	open_namespace (const String &ns) override

MutatorAsync	async_mutator_open (const ThriftGen::Namespace ns, const String &table, const ThriftGen::Future ff,::int32_t flags) override

MutatorAsync	open_mutator_async (const ThriftGen::Namespace ns, const String &table, const ThriftGen::Future ff,::int32_t flags) override

Mutator	mutator_open (const ThriftGen::Namespace ns, const String &table, int32_t flags, int32_t flush_interval) override

Mutator	open_mutator (const ThriftGen::Namespace ns, const String &table, int32_t flags, int32_t flush_interval) override

void	mutator_flush (const Mutator mutator) override

void	flush_mutator (const Mutator mutator) override

void	async_mutator_flush (const MutatorAsync mutator) override

void	flush_mutator_async (const MutatorAsync mutator) override

void	mutator_close (const Mutator mutator) override

void	close_mutator (const Mutator mutator) override

void	async_mutator_cancel (const MutatorAsync mutator) override

void	cancel_mutator_async (const MutatorAsync mutator) override

void	async_mutator_close (const MutatorAsync mutator) override

void	close_mutator_async (const MutatorAsync mutator) override

void	mutator_set_cells (const Mutator mutator, const ThriftCells &cells) override

void	mutator_set_cell (const Mutator mutator, const ThriftGen::Cell &cell) override

void	mutator_set_cells_as_arrays (const Mutator mutator, const ThriftCellsAsArrays &cells) override

void	mutator_set_cell_as_array (const Mutator mutator, const CellAsArray &cell) override

void	mutator_set_cells_serialized (const Mutator mutator, const CellsSerialized &cells, const bool flush) override

void	set_cell (const ThriftGen::Namespace ns, const String &table, const ThriftGen::Cell &cell) override

void	set_cells (const ThriftGen::Namespace ns, const String &table, const ThriftCells &cells) override

void	set_cells_as_arrays (const ThriftGen::Namespace ns, const String &table, const ThriftCellsAsArrays &cells) override

void	set_cell_as_array (const ThriftGen::Namespace ns, const String &table, const CellAsArray &cell) override

void	set_cells_serialized (const ThriftGen::Namespace ns, const String &table, const CellsSerialized &cells) override

void	async_mutator_set_cells (const MutatorAsync mutator, const ThriftCells &cells) override

void	set_cells_async (const MutatorAsync mutator, const ThriftCells &cells) override

void	async_mutator_set_cell (const MutatorAsync mutator, const ThriftGen::Cell &cell) override

void	set_cell_async (const MutatorAsync mutator, const ThriftGen::Cell &cell) override

void	async_mutator_set_cells_as_arrays (const MutatorAsync mutator, const ThriftCellsAsArrays &cells) override

void	set_cells_as_arrays_async (const MutatorAsync mutator, const ThriftCellsAsArrays &cells) override

void	async_mutator_set_cell_as_array (const MutatorAsync mutator, const CellAsArray &cell) override

void	set_cell_as_array_async (const MutatorAsync mutator, const CellAsArray &cell) override

void	async_mutator_set_cells_serialized (const MutatorAsync mutator, const CellsSerialized &cells, const bool flush) override

void	set_cells_serialized_async (const MutatorAsync mutator, const CellsSerialized &cells, const bool flush) override

bool	namespace_exists (const String &ns) override

bool	exists_namespace (const String &ns) override

bool	table_exists (const ThriftGen::Namespace ns, const String &table) override

bool	exists_table (const ThriftGen::Namespace ns, const String &table) override

void	table_get_id (String &result, const ThriftGen::Namespace ns, const String &table) override

void	get_table_id (String &result, const ThriftGen::Namespace ns, const String &table) override

void	table_get_schema_str (String &result, const ThriftGen::Namespace ns, const String &table) override

void	get_schema_str (String &result, const ThriftGen::Namespace ns, const String &table) override

void	table_get_schema_str_with_ids (String &result, const ThriftGen::Namespace ns, const String &table) override

void	get_schema_str_with_ids (String &result, const ThriftGen::Namespace ns, const String &table) override

void	table_get_schema (ThriftGen::Schema &result, const ThriftGen::Namespace ns, const String &table) override

void	get_schema (ThriftGen::Schema &result, const ThriftGen::Namespace ns, const String &table) override

void	get_tables (std::vector< String > &tables, const ThriftGen::Namespace ns) override

void	namespace_get_listing (std::vector< ThriftGen::NamespaceListing > &_return, const ThriftGen::Namespace ns) override

void	get_listing (std::vector< ThriftGen::NamespaceListing > &_return, const ThriftGen::Namespace ns) override

void	table_get_splits (std::vector< ThriftGen::TableSplit > &_return, const ThriftGen::Namespace ns, const String &table) override

void	get_table_splits (std::vector< ThriftGen::TableSplit > &_return, const ThriftGen::Namespace ns, const String &table) override

void	namespace_drop (const String &ns, const bool if_exists) override

void	drop_namespace (const String &ns, const bool if_exists) override

void	table_rename (const ThriftGen::Namespace ns, const String &table, const String &new_table_name) override

void	rename_table (const ThriftGen::Namespace ns, const String &table, const String &new_table_name) override

void	table_drop (const ThriftGen::Namespace ns, const String &table, const bool if_exists) override

void	drop_table (const ThriftGen::Namespace ns, const String &table, const bool if_exists) override

void	generate_guid (std::string &_return) override

void	create_cell_unique (std::string &_return, const ThriftGen::Namespace ns, const std::string &table_name, const ThriftGen::Key &tkey, const std::string &value) override

void	status (ThriftGen::Status &_return) override

void	shutdown () override

void	error_get_text (std::string &_return, int error_code) override

void	_convert_result (const Hypertable::ResultPtr &hresult, ThriftGen::Result &tresult)

void	_convert_result_as_arrays (const Hypertable::ResultPtr &hresult, ThriftGen::ResultAsArrays &tresult)

void	_convert_result_serialized (Hypertable::ResultPtr &hresult, ThriftGen::ResultSerialized &tresult)

TableMutatorAsync *	_open_mutator_async (const ThriftGen::Namespace ns, const String &table, const ThriftGen::Future ff,::int32_t flags)

TableScannerAsync *	_open_scanner_async (const ThriftGen::Namespace ns, const String &table, const ThriftGen::Future ff, const ThriftGen::ScanSpec &ss)

TableScanner *	_open_scanner (const ThriftGen::Namespace ns, const String &table, const Hypertable::ScanSpec &ss)

TableMutator *	_open_mutator (const ThriftGen::Namespace ns, const String &table)

template<class CellT >
void	_next (vector< CellT > &result, TableScanner *scanner, int limit)

template<class CellT >
void	_next_row (vector< CellT > &result, TableScanner *scanner)

void	run_hql_interp (const ThriftGen::Namespace ns, const String &hql, HqlInterpreter::Callback &cb)

template<class CellT >
void	_offer_cells (const ThriftGen::Namespace ns, const String &table, const ThriftGen::MutateSpec &mutate_spec, const vector< CellT > &cells)

template<class CellT >
void	_offer_cell (const ThriftGen::Namespace ns, const String &table, const ThriftGen::MutateSpec &mutate_spec, const CellT &cell)

template<class CellT >
void	_set_cells (const Mutator mutator, const vector< CellT > &cells)

template<class CellT >
void	_set_cell (const Mutator mutator, const CellT &cell)

template<class CellT >
void	_set_cells_async (const MutatorAsync mutator, const vector< CellT > &cells)

template<class CellT >
void	_set_cell_async (const MutatorAsync mutator, const CellT &cell)

ClientObject *	get_object (int64_t id)

ClientObject *	get_cached_object (int64_t id)

Hypertable::Future *	get_future (int64_t id)

Hypertable::Namespace *	get_namespace (int64_t id)

int64_t	get_cached_object_id (ClientObjectPtr co)

int64_t	get_object_id (ClientObject *co)

int64_t	get_object_id (TableMutatorPtr &mutator)

int64_t	try_get_object_id (ClientObject *co)

int64_t	get_scanner_id (TableScanner *scanner, ScannerInfoPtr &info)

int64_t	get_scanner_id (TableScannerPtr &scanner, ScannerInfoPtr &info)

void	add_reference (int64_t from, int64_t to)

void	remove_references (int64_t id)

TableScannerAsync *	get_scanner_async (int64_t id)

TableScanner *	get_scanner (int64_t id, ScannerInfoPtr &info)

bool	remove_object (int64_t id)

bool	remove_cached_object (int64_t id)

void	remove_scanner (int64_t id)

void	remove_scanner (int64_t id, ClientObjectPtr &scanner, ScannerInfoPtr &info)

void	shared_mutator_refresh (const ThriftGen::Namespace ns, const String &table, const ThriftGen::MutateSpec &mutate_spec) override

void	refresh_shared_mutator (const ThriftGen::Namespace ns, const String &table, const ThriftGen::MutateSpec &mutate_spec) override

TableMutator *	get_shared_mutator (const ThriftGen::Namespace ns, const String &table, const ThriftGen::MutateSpec &mutate_spec)

TableMutator *	get_mutator (int64_t id)

TableMutatorAsync *	get_mutator_async (int64_t id)

void	remove_future (int64_t id)

void	remove_namespace (int64_t id)

void	remove_mutator (int64_t id)

Private Attributes
String	m_remote_peer

Context &	m_context

std::mutex	m_mutex

multimap<::int64_t, ClientObjectPtr >	m_reference_map

ObjectMap	m_object_map

ObjectMap	m_cached_object_map

std::unordered_map< ::int64_t, ScannerInfoPtr >	m_scanner_info_map

Detailed Description

Definition at line 917 of file ThriftBroker.cc.

Constructor & Destructor Documentation

Hypertable::ThriftBroker::ServerHandler::ServerHandler	(	const String &	remote_peer,
		Context &	c
	)

inline

Definition at line 955 of file ThriftBroker.cc.

virtual Hypertable::ThriftBroker::ServerHandler::~ServerHandler ( )

inlinevirtual

Definition at line 959 of file ThriftBroker.cc.

Member Function Documentation

void Hypertable::ThriftBroker::ServerHandler::_convert_result	(	const Hypertable::ResultPtr &	hresult,
		ThriftGen::Result &	tresult
	)

inline

Definition at line 2499 of file ThriftBroker.cc.

void Hypertable::ThriftBroker::ServerHandler::_convert_result_as_arrays	(	const Hypertable::ResultPtr &	hresult,
		ThriftGen::ResultAsArrays &	tresult
	)

inline

Definition at line 2533 of file ThriftBroker.cc.

void Hypertable::ThriftBroker::ServerHandler::_convert_result_serialized	(	Hypertable::ResultPtr &	hresult,
		ThriftGen::ResultSerialized &	tresult
	)

inline

Definition at line 2559 of file ThriftBroker.cc.

template<class CellT >

void Hypertable::ThriftBroker::ServerHandler::_next	(	vector< CellT > &	result,
		TableScanner *	scanner,
		int	limit
	)

inline

Definition at line 2621 of file ThriftBroker.cc.

template<class CellT >

void Hypertable::ThriftBroker::ServerHandler::_next_row	(	vector< CellT > &	result,
		TableScanner *	scanner
	)

inline

Definition at line 2637 of file ThriftBroker.cc.

template<class CellT >

void Hypertable::ThriftBroker::ServerHandler::_offer_cell	(	const ThriftGen::Namespace	ns,
		const String &	table,
		const ThriftGen::MutateSpec &	mutate_spec,
		const CellT &	cell
	)

inline

Definition at line 2674 of file ThriftBroker.cc.

template<class CellT >

void Hypertable::ThriftBroker::ServerHandler::_offer_cells	(	const ThriftGen::Namespace	ns,
		const String &	table,
		const ThriftGen::MutateSpec &	mutate_spec,
		const vector< CellT > &	cells
	)

inline

Definition at line 2665 of file ThriftBroker.cc.

TableMutator* Hypertable::ThriftBroker::ServerHandler::_open_mutator	(	const ThriftGen::Namespace	ns,
		const String &	table
	)

inline

Definition at line 2613 of file ThriftBroker.cc.

TableMutatorAsync* Hypertable::ThriftBroker::ServerHandler::_open_mutator_async	(	const ThriftGen::Namespace	ns,
		const String &	table,
		const ThriftGen::Future	ff,
		::int32_t	flags
	)

inline

Definition at line 2585 of file ThriftBroker.cc.

TableScanner* Hypertable::ThriftBroker::ServerHandler::_open_scanner	(	const ThriftGen::Namespace	ns,
		const String &	table,
		const Hypertable::ScanSpec &	ss
	)

inline

Definition at line 2606 of file ThriftBroker.cc.

TableScannerAsync* Hypertable::ThriftBroker::ServerHandler::_open_scanner_async	(	const ThriftGen::Namespace	ns,
		const String &	table,
		const ThriftGen::Future	ff,
		const ThriftGen::ScanSpec &	ss
	)

inline

Definition at line 2594 of file ThriftBroker.cc.

template<class CellT >

void Hypertable::ThriftBroker::ServerHandler::_set_cell	(	const Mutator	mutator,
		const CellT &	cell
	)

inline

Definition at line 2691 of file ThriftBroker.cc.

template<class CellT >

void Hypertable::ThriftBroker::ServerHandler::_set_cell_async	(	const MutatorAsync	mutator,
		const CellT &	cell
	)

inline

Definition at line 2710 of file ThriftBroker.cc.

template<class CellT >

void Hypertable::ThriftBroker::ServerHandler::_set_cells	(	const Mutator	mutator,
		const vector< CellT > &	cells
	)

inline

Definition at line 2684 of file ThriftBroker.cc.

template<class CellT >

void Hypertable::ThriftBroker::ServerHandler::_set_cells_async	(	const MutatorAsync	mutator,
		const vector< CellT > &	cells
	)

inline

Definition at line 2700 of file ThriftBroker.cc.

void Hypertable::ThriftBroker::ServerHandler::add_reference	(	int64_t	from,
		int64_t	to
	)

inline

Definition at line 2797 of file ThriftBroker.cc.

void Hypertable::ThriftBroker::ServerHandler::async_mutator_cancel ( const MutatorAsync mutator )

inlineoverride

Definition at line 1984 of file ThriftBroker.cc.

void Hypertable::ThriftBroker::ServerHandler::async_mutator_close ( const MutatorAsync mutator )

inlineoverride

Definition at line 1998 of file ThriftBroker.cc.

void Hypertable::ThriftBroker::ServerHandler::async_mutator_flush ( const MutatorAsync mutator )

inlineoverride

Definition at line 1959 of file ThriftBroker.cc.

MutatorAsync Hypertable::ThriftBroker::ServerHandler::async_mutator_open	(	const ThriftGen::Namespace	ns,
		const String &	table,
		const ThriftGen::Future	ff,
		::int32_t	flags
	)

inlineoverride

Definition at line 1908 of file ThriftBroker.cc.

void Hypertable::ThriftBroker::ServerHandler::async_mutator_set_cell	(	const MutatorAsync	mutator,
		const ThriftGen::Cell &	cell
	)

inlineoverride

Definition at line 2170 of file ThriftBroker.cc.

void Hypertable::ThriftBroker::ServerHandler::async_mutator_set_cell_as_array	(	const MutatorAsync	mutator,
		const CellAsArray &	cell
	)

inlineoverride

Definition at line 2198 of file ThriftBroker.cc.

void Hypertable::ThriftBroker::ServerHandler::async_mutator_set_cells	(	const MutatorAsync	mutator,
		const ThriftCells &	cells
	)

inlineoverride

Definition at line 2156 of file ThriftBroker.cc.

void Hypertable::ThriftBroker::ServerHandler::async_mutator_set_cells_as_arrays	(	const MutatorAsync	mutator,
		const ThriftCellsAsArrays &	cells
	)

inlineoverride

Definition at line 2184 of file ThriftBroker.cc.

void Hypertable::ThriftBroker::ServerHandler::async_mutator_set_cells_serialized	(	const MutatorAsync	mutator,
		const CellsSerialized &	cells,
		const bool	flush
	)

inlineoverride

Definition at line 2214 of file ThriftBroker.cc.

void Hypertable::ThriftBroker::ServerHandler::async_scanner_cancel ( const ScannerAsync scanner )

inlineoverride

Definition at line 1329 of file ThriftBroker.cc.

void Hypertable::ThriftBroker::ServerHandler::async_scanner_close ( const ScannerAsync scanner_async )

inlineoverride

Definition at line 1343 of file ThriftBroker.cc.

ScannerAsync Hypertable::ThriftBroker::ServerHandler::async_scanner_open	(	const ThriftGen::Namespace	ns,
		const String &	table,
		const ThriftGen::Future	ff,
		const ThriftGen::ScanSpec &	ss
	)

inlineoverride

Definition at line 1252 of file ThriftBroker.cc.

void Hypertable::ThriftBroker::ServerHandler::cancel_future ( ThriftGen::Future ff )

inlineoverride

Definition at line 1834 of file ThriftBroker.cc.

void Hypertable::ThriftBroker::ServerHandler::cancel_mutator_async ( const MutatorAsync mutator )

inlineoverride

Definition at line 1994 of file ThriftBroker.cc.

void Hypertable::ThriftBroker::ServerHandler::cancel_scanner_async ( const ScannerAsync scanner )

inlineoverride

Definition at line 1339 of file ThriftBroker.cc.

void Hypertable::ThriftBroker::ServerHandler::close_future ( const ThriftGen::Future ff )

inlineoverride

Definition at line 1890 of file ThriftBroker.cc.

void Hypertable::ThriftBroker::ServerHandler::close_mutator ( const Mutator mutator )

inlineoverride

Definition at line 1980 of file ThriftBroker.cc.

void Hypertable::ThriftBroker::ServerHandler::close_mutator_async ( const MutatorAsync mutator )

inlineoverride

Definition at line 2008 of file ThriftBroker.cc.

void Hypertable::ThriftBroker::ServerHandler::close_namespace ( const ThriftGen::Namespace ns )

inlineoverride

Definition at line 1282 of file ThriftBroker.cc.

void Hypertable::ThriftBroker::ServerHandler::close_scanner ( const Scanner scanner )

inlineoverride

Definition at line 1325 of file ThriftBroker.cc.

void Hypertable::ThriftBroker::ServerHandler::close_scanner_async ( const ScannerAsync scanner_async )

inlineoverride

Definition at line 1352 of file ThriftBroker.cc.

void Hypertable::ThriftBroker::ServerHandler::create_cell_unique	(	std::string &	_return,
		const ThriftGen::Namespace	ns,
		const std::string &	table_name,
		const ThriftGen::Key &	tkey,
		const std::string &	value
	)

inlineoverride

Definition at line 2460 of file ThriftBroker.cc.

void Hypertable::ThriftBroker::ServerHandler::create_namespace ( const String & ns )

inlineoverride

Definition at line 1202 of file ThriftBroker.cc.

void Hypertable::ThriftBroker::ServerHandler::drop_namespace	(	const String &	ns,
		const bool	if_exists
	)

inlineoverride

Definition at line 2411 of file ThriftBroker.cc.

void Hypertable::ThriftBroker::ServerHandler::drop_table	(	const ThriftGen::Namespace	ns,
		const String &	table,
		const bool	if_exists
	)

inlineoverride

Definition at line 2446 of file ThriftBroker.cc.

void Hypertable::ThriftBroker::ServerHandler::error_get_text	(	std::string &	_return,
		int	error_code
	)

inlineoverride

Definition at line 2492 of file ThriftBroker.cc.

bool Hypertable::ThriftBroker::ServerHandler::exists_namespace ( const String & ns )

inlineoverride

Definition at line 2252 of file ThriftBroker.cc.

bool Hypertable::ThriftBroker::ServerHandler::exists_table	(	const ThriftGen::Namespace	ns,
		const String &	table
	)

inlineoverride

Definition at line 2268 of file ThriftBroker.cc.

void Hypertable::ThriftBroker::ServerHandler::flush_mutator ( const Mutator mutator )

inlineoverride

Definition at line 1955 of file ThriftBroker.cc.

void Hypertable::ThriftBroker::ServerHandler::flush_mutator_async ( const MutatorAsync mutator )

inlineoverride

Definition at line 1967 of file ThriftBroker.cc.

void Hypertable::ThriftBroker::ServerHandler::future_cancel ( ThriftGen::Future ff )

inlineoverride

Definition at line 1824 of file ThriftBroker.cc.

void Hypertable::ThriftBroker::ServerHandler::future_close ( const ThriftGen::Future ff )

inlineoverride

Definition at line 1882 of file ThriftBroker.cc.

void Hypertable::ThriftBroker::ServerHandler::future_get_result	(	ThriftGen::Result &	tresult,
		ThriftGen::Future	ff,
		int	timeout_millis
	)

inlineoverride

Definition at line 1729 of file ThriftBroker.cc.

void Hypertable::ThriftBroker::ServerHandler::future_get_result_as_arrays	(	ThriftGen::ResultAsArrays &	tresult,
		ThriftGen::Future	ff,
		int	timeout_millis
	)

inlineoverride

Definition at line 1761 of file ThriftBroker.cc.

void Hypertable::ThriftBroker::ServerHandler::future_get_result_serialized	(	ThriftGen::ResultSerialized &	tresult,
		ThriftGen::Future	ff,
		int	timeout_millis
	)

inlineoverride

Definition at line 1792 of file ThriftBroker.cc.

bool Hypertable::ThriftBroker::ServerHandler::future_has_outstanding ( ThriftGen::Future ff )

inlineoverride

Definition at line 1871 of file ThriftBroker.cc.

bool Hypertable::ThriftBroker::ServerHandler::future_is_cancelled ( ThriftGen::Future ff )

inlineoverride

Definition at line 1860 of file ThriftBroker.cc.

bool Hypertable::ThriftBroker::ServerHandler::future_is_empty ( ThriftGen::Future ff )

inlineoverride

Definition at line 1838 of file ThriftBroker.cc.

bool Hypertable::ThriftBroker::ServerHandler::future_is_full ( ThriftGen::Future ff )

inlineoverride

Definition at line 1849 of file ThriftBroker.cc.

ThriftGen::Future Hypertable::ThriftBroker::ServerHandler::future_open ( int capacity )

inlineoverride

Definition at line 1714 of file ThriftBroker.cc.

void Hypertable::ThriftBroker::ServerHandler::generate_guid ( std::string & _return )

inlineoverride

Definition at line 2451 of file ThriftBroker.cc.

ClientObject* Hypertable::ThriftBroker::ServerHandler::get_cached_object ( int64_t id )

inline

Definition at line 2727 of file ThriftBroker.cc.

int64_t Hypertable::ThriftBroker::ServerHandler::get_cached_object_id ( ClientObjectPtr co )

inline

Definition at line 2754 of file ThriftBroker.cc.

void Hypertable::ThriftBroker::ServerHandler::get_cell	(	Value &	result,
		const ThriftGen::Namespace	ns,
		const String &	table,
		const String &	row,
		const String &	column
	)

inlineoverride

Definition at line 1554 of file ThriftBroker.cc.

void Hypertable::ThriftBroker::ServerHandler::get_cells	(	ThriftCells &	result,
		const ThriftGen::Namespace	ns,
		const String &	table,
		const ThriftGen::ScanSpec &	ss
	)

inlineoverride

Definition at line 1585 of file ThriftBroker.cc.

void Hypertable::ThriftBroker::ServerHandler::get_cells_as_arrays	(	ThriftCellsAsArrays &	result,
		const ThriftGen::Namespace	ns,
		const String &	table,
		const ThriftGen::ScanSpec &	ss
	)

inlineoverride

Definition at line 1600 of file ThriftBroker.cc.

void Hypertable::ThriftBroker::ServerHandler::get_cells_serialized	(	CellsSerialized &	result,
		const ThriftGen::Namespace	ns,
		const String &	table,
		const ThriftGen::ScanSpec &	ss
	)

inlineoverride

Definition at line 1615 of file ThriftBroker.cc.

Hypertable::Future* Hypertable::ThriftBroker::ServerHandler::get_future ( int64_t id )

inline

Definition at line 2733 of file ThriftBroker.cc.

void Hypertable::ThriftBroker::ServerHandler::get_future_result	(	ThriftGen::Result &	tresult,
		ThriftGen::Future	ff,
		int	timeout_millis
	)

inlineoverride

Definition at line 1756 of file ThriftBroker.cc.

void Hypertable::ThriftBroker::ServerHandler::get_future_result_as_arrays	(	ThriftGen::ResultAsArrays &	tresult,
		ThriftGen::Future	ff,
		int	timeout_millis
	)

inlineoverride

Definition at line 1787 of file ThriftBroker.cc.

void Hypertable::ThriftBroker::ServerHandler::get_future_result_serialized	(	ThriftGen::ResultSerialized &	tresult,
		ThriftGen::Future	ff,
		int	timeout_millis
	)

inlineoverride

Definition at line 1819 of file ThriftBroker.cc.

void Hypertable::ThriftBroker::ServerHandler::get_listing	(	std::vector< ThriftGen::NamespaceListing > &	_return,
		const ThriftGen::Namespace	ns
	)

inlineoverride

Definition at line 2372 of file ThriftBroker.cc.

TableMutator* Hypertable::ThriftBroker::ServerHandler::get_mutator ( int64_t id )

inline

Definition at line 2957 of file ThriftBroker.cc.

TableMutatorAsync* Hypertable::ThriftBroker::ServerHandler::get_mutator_async ( int64_t id )

inline

Definition at line 2967 of file ThriftBroker.cc.

Hypertable::Namespace* Hypertable::ThriftBroker::ServerHandler::get_namespace ( int64_t id )

inline

Definition at line 2744 of file ThriftBroker.cc.

ClientObject* Hypertable::ThriftBroker::ServerHandler::get_object ( int64_t id )

inline

Definition at line 2721 of file ThriftBroker.cc.

int64_t Hypertable::ThriftBroker::ServerHandler::get_object_id ( ClientObject * co )

inline

Definition at line 2761 of file ThriftBroker.cc.

int64_t Hypertable::ThriftBroker::ServerHandler::get_object_id ( TableMutatorPtr & mutator )

inline

Definition at line 2768 of file ThriftBroker.cc.

void Hypertable::ThriftBroker::ServerHandler::get_row	(	ThriftCells &	result,
		const ThriftGen::Namespace	ns,
		const String &	table,
		const String &	row
	)

inlineoverride

Definition at line 1492 of file ThriftBroker.cc.

void Hypertable::ThriftBroker::ServerHandler::get_row_as_arrays	(	ThriftCellsAsArrays &	result,
		const ThriftGen::Namespace	ns,
		const String &	table,
		const String &	row
	)

inlineoverride

Definition at line 1509 of file ThriftBroker.cc.

void Hypertable::ThriftBroker::ServerHandler::get_row_serialized	(	CellsSerialized &	result,
		const ThriftGen::Namespace	ns,
		const std::string &	table,
		const std::string &	row
	)

inlineoverride

Definition at line 1528 of file ThriftBroker.cc.

TableScanner* Hypertable::ThriftBroker::ServerHandler::get_scanner	(	int64_t	id,
		ScannerInfoPtr &	info
	)

inline

Definition at line 2820 of file ThriftBroker.cc.

TableScannerAsync* Hypertable::ThriftBroker::ServerHandler::get_scanner_async ( int64_t id )

inline

Definition at line 2809 of file ThriftBroker.cc.

int64_t Hypertable::ThriftBroker::ServerHandler::get_scanner_id	(	TableScanner *	scanner,
		ScannerInfoPtr &	info
	)

inline

Definition at line 2781 of file ThriftBroker.cc.

int64_t Hypertable::ThriftBroker::ServerHandler::get_scanner_id	(	TableScannerPtr &	scanner,
		ScannerInfoPtr &	info
	)

inline

Definition at line 2789 of file ThriftBroker.cc.

void Hypertable::ThriftBroker::ServerHandler::get_schema	(	ThriftGen::Schema &	result,
		const ThriftGen::Namespace	ns,
		const String &	table
	)

inlineoverride

Definition at line 2330 of file ThriftBroker.cc.

void Hypertable::ThriftBroker::ServerHandler::get_schema_str	(	String &	result,
		const ThriftGen::Namespace	ns,
		const String &	table
	)

inlineoverride

Definition at line 2298 of file ThriftBroker.cc.

void Hypertable::ThriftBroker::ServerHandler::get_schema_str_with_ids	(	String &	result,
		const ThriftGen::Namespace	ns,
		const String &	table
	)

inlineoverride

Definition at line 2313 of file ThriftBroker.cc.

TableMutator* Hypertable::ThriftBroker::ServerHandler::get_shared_mutator	(	const ThriftGen::Namespace	ns,
		const String &	table,
		const ThriftGen::MutateSpec &	mutate_spec
	)

inline

Definition at line 2934 of file ThriftBroker.cc.

void Hypertable::ThriftBroker::ServerHandler::get_table_id	(	String &	result,
		const ThriftGen::Namespace	ns,
		const String &	table
	)

inlineoverride

Definition at line 2283 of file ThriftBroker.cc.

void Hypertable::ThriftBroker::ServerHandler::get_table_splits	(	std::vector< ThriftGen::TableSplit > &	_return,
		const ThriftGen::Namespace	ns,
		const String &	table
	)

inlineoverride

Definition at line 2397 of file ThriftBroker.cc.

void Hypertable::ThriftBroker::ServerHandler::get_tables	(	std::vector< String > &	tables,
		const ThriftGen::Namespace	ns
	)

inlineoverride

Definition at line 2335 of file ThriftBroker.cc.

void Hypertable::ThriftBroker::ServerHandler::hql_exec	(	HqlResult &	result,
		const ThriftGen::Namespace	ns,
		const String &	hql,
		bool	noflush,
		bool	unbuffered
	)

inlineoverride

Definition at line 1110 of file ThriftBroker.cc.

void Hypertable::ThriftBroker::ServerHandler::hql_exec2	(	HqlResult2 &	result,
		const ThriftGen::Namespace	ns,
		const String &	hql,
		bool	noflush,
		bool	unbuffered
	)

inlineoverride

Definition at line 1141 of file ThriftBroker.cc.

void Hypertable::ThriftBroker::ServerHandler::hql_exec_as_arrays	(	HqlResultAsArrays &	result,
		const ThriftGen::Namespace	ns,
		const String &	hql,
		bool	noflush,
		bool	unbuffered
	)

inlineoverride

Definition at line 1162 of file ThriftBroker.cc.

void Hypertable::ThriftBroker::ServerHandler::hql_query	(	HqlResult &	result,
		const ThriftGen::Namespace	ns,
		const String &	hql
	)

inlineoverride

Definition at line 1135 of file ThriftBroker.cc.

void Hypertable::ThriftBroker::ServerHandler::hql_query2	(	HqlResult2 &	result,
		const ThriftGen::Namespace	ns,
		const String &	hql
	)

inlineoverride

Definition at line 1183 of file ThriftBroker.cc.

void Hypertable::ThriftBroker::ServerHandler::hql_query_as_arrays	(	HqlResultAsArrays &	result,
		const ThriftGen::Namespace	ns,
		const String &	hql
	)

inlineoverride

Definition at line 1189 of file ThriftBroker.cc.

void Hypertable::ThriftBroker::ServerHandler::log_slow_query	(	const char *	func_name,
		std::chrono::fast_clock::time_point	start_time,
		std::chrono::fast_clock::time_point	end_time,
		int64_t	latency_ms,
		ProfileDataScanner &	profile_data,
		Hypertable::Namespace *	ns,
		const string &	hql
	)

inline

Definition at line 1016 of file ThriftBroker.cc.

void Hypertable::ThriftBroker::ServerHandler::log_slow_query_scanspec	(	const char *	func_name,
		std::chrono::fast_clock::time_point	start_time,
		std::chrono::fast_clock::time_point	end_time,
		int64_t	latency_ms,
		ProfileDataScanner &	profile_data,
		Hypertable::Namespace *	ns,
		const string &	table,
		Hypertable::ScanSpec &	ss
	)

inline

Definition at line 1071 of file ThriftBroker.cc.

void Hypertable::ThriftBroker::ServerHandler::mutator_close ( const Mutator mutator )

inlineoverride

Definition at line 1971 of file ThriftBroker.cc.

void Hypertable::ThriftBroker::ServerHandler::mutator_flush ( const Mutator mutator )

inlineoverride

Definition at line 1947 of file ThriftBroker.cc.

Mutator Hypertable::ThriftBroker::ServerHandler::mutator_open	(	const ThriftGen::Namespace	ns,
		const String &	table,
		int32_t	flags,
		int32_t	flush_interval
	)

inlineoverride

Definition at line 1927 of file ThriftBroker.cc.

void Hypertable::ThriftBroker::ServerHandler::mutator_set_cell	(	const Mutator	mutator,
		const ThriftGen::Cell &	cell
	)

inlineoverride

Definition at line 2021 of file ThriftBroker.cc.

void Hypertable::ThriftBroker::ServerHandler::mutator_set_cell_as_array	(	const Mutator	mutator,
		const CellAsArray &	cell
	)

inlineoverride

Definition at line 2039 of file ThriftBroker.cc.

void Hypertable::ThriftBroker::ServerHandler::mutator_set_cells	(	const Mutator	mutator,
		const ThriftCells &	cells
	)

inlineoverride

Definition at line 2012 of file ThriftBroker.cc.

void Hypertable::ThriftBroker::ServerHandler::mutator_set_cells_as_arrays	(	const Mutator	mutator,
		const ThriftCellsAsArrays &	cells
	)

inlineoverride

Definition at line 2030 of file ThriftBroker.cc.

void Hypertable::ThriftBroker::ServerHandler::mutator_set_cells_serialized	(	const Mutator	mutator,
		const CellsSerialized &	cells,
		const bool	flush
	)

inlineoverride

Definition at line 2050 of file ThriftBroker.cc.

void Hypertable::ThriftBroker::ServerHandler::namespace_close ( const ThriftGen::Namespace ns )

inlineoverride

Definition at line 1274 of file ThriftBroker.cc.

void Hypertable::ThriftBroker::ServerHandler::namespace_create ( const String & ns )

inlineoverride

Definition at line 1194 of file ThriftBroker.cc.

void Hypertable::ThriftBroker::ServerHandler::namespace_drop	(	const String &	ns,
		const bool	if_exists
	)

inlineoverride

Definition at line 2402 of file ThriftBroker.cc.

bool Hypertable::ThriftBroker::ServerHandler::namespace_exists ( const String & ns )

inlineoverride

Definition at line 2242 of file ThriftBroker.cc.

void Hypertable::ThriftBroker::ServerHandler::namespace_get_listing	(	std::vector< ThriftGen::NamespaceListing > &	_return,
		const ThriftGen::Namespace	ns
	)

inlineoverride

Definition at line 2352 of file ThriftBroker.cc.

ThriftGen::Namespace Hypertable::ThriftBroker::ServerHandler::namespace_open ( const String & ns )

inlineoverride

Definition at line 1894 of file ThriftBroker.cc.

void Hypertable::ThriftBroker::ServerHandler::next_cells	(	ThriftCells &	result,
		const Scanner	scanner_id
	)

inlineoverride

Definition at line 1366 of file ThriftBroker.cc.

void Hypertable::ThriftBroker::ServerHandler::next_cells_as_arrays	(	ThriftCellsAsArrays &	result,
		const Scanner	scanner_id
	)

inlineoverride

Definition at line 1380 of file ThriftBroker.cc.

void Hypertable::ThriftBroker::ServerHandler::next_cells_serialized	(	CellsSerialized &	result,
		const Scanner	scanner_id
	)

inlineoverride

Definition at line 1414 of file ThriftBroker.cc.

void Hypertable::ThriftBroker::ServerHandler::next_row	(	ThriftCells &	result,
		const Scanner	scanner_id
	)

inlineoverride

Definition at line 1429 of file ThriftBroker.cc.

void Hypertable::ThriftBroker::ServerHandler::next_row_as_arrays	(	ThriftCellsAsArrays &	result,
		const Scanner	scanner_id
	)

inlineoverride

Definition at line 1443 of file ThriftBroker.cc.

void Hypertable::ThriftBroker::ServerHandler::next_row_serialized	(	CellsSerialized &	result,
		const Scanner	scanner_id
	)

inlineoverride

Definition at line 1487 of file ThriftBroker.cc.

void Hypertable::ThriftBroker::ServerHandler::offer_cell	(	const ThriftGen::Namespace	ns,
		const String &	table,
		const ThriftGen::MutateSpec &	mutate_spec,
		const ThriftGen::Cell &	cell
	)

inlineoverride

Definition at line 1668 of file ThriftBroker.cc.

void Hypertable::ThriftBroker::ServerHandler::offer_cell_as_array	(	const ThriftGen::Namespace	ns,
		const String &	table,
		const ThriftGen::MutateSpec &	mutate_spec,
		const CellAsArray &	cell
	)

inlineoverride

Definition at line 1708 of file ThriftBroker.cc.

void Hypertable::ThriftBroker::ServerHandler::offer_cells	(	const ThriftGen::Namespace	ns,
		const String &	table,
		const ThriftGen::MutateSpec &	mutate_spec,
		const ThriftCells &	cells
	)

inlineoverride

Definition at line 1650 of file ThriftBroker.cc.

void Hypertable::ThriftBroker::ServerHandler::offer_cells_as_arrays	(	const ThriftGen::Namespace	ns,
		const String &	table,
		const ThriftGen::MutateSpec &	mutate_spec,
		const ThriftCellsAsArrays &	cells
	)

inlineoverride

Definition at line 1687 of file ThriftBroker.cc.

ThriftGen::Future Hypertable::ThriftBroker::ServerHandler::open_future ( int capacity )

inlineoverride

Definition at line 1725 of file ThriftBroker.cc.

Mutator Hypertable::ThriftBroker::ServerHandler::open_mutator	(	const ThriftGen::Namespace	ns,
		const String &	table,
		int32_t	flags,
		int32_t	flush_interval
	)

inlineoverride

Definition at line 1942 of file ThriftBroker.cc.

MutatorAsync Hypertable::ThriftBroker::ServerHandler::open_mutator_async	(	const ThriftGen::Namespace	ns,
		const String &	table,
		const ThriftGen::Future	ff,
		::int32_t	flags
	)

inlineoverride

Definition at line 1922 of file ThriftBroker.cc.

ThriftGen::Namespace Hypertable::ThriftBroker::ServerHandler::open_namespace ( const String & ns )

inlineoverride

Definition at line 1904 of file ThriftBroker.cc.

Scanner Hypertable::ThriftBroker::ServerHandler::open_scanner	(	const ThriftGen::Namespace	ns,
		const String &	table,
		const ThriftGen::ScanSpec &	ss
	)

inlineoverride

Definition at line 1247 of file ThriftBroker.cc.

ScannerAsync Hypertable::ThriftBroker::ServerHandler::open_scanner_async	(	const ThriftGen::Namespace	ns,
		const String &	table,
		const ThriftGen::Future	ff,
		const ThriftGen::ScanSpec &	ss
	)

inlineoverride

Definition at line 1268 of file ThriftBroker.cc.

void Hypertable::ThriftBroker::ServerHandler::refresh_shared_mutator	(	const ThriftGen::Namespace	ns,
		const String &	table,
		const ThriftGen::MutateSpec &	mutate_spec
	)

inlineoverride

Definition at line 2929 of file ThriftBroker.cc.

void Hypertable::ThriftBroker::ServerHandler::refresh_table	(	const ThriftGen::Namespace	ns,
		const String &	table_name
	)

inlineoverride

Definition at line 1286 of file ThriftBroker.cc.

const String& Hypertable::ThriftBroker::ServerHandler::remote_peer ( ) const

inline

Definition at line 1012 of file ThriftBroker.cc.

bool Hypertable::ThriftBroker::ServerHandler::remove_cached_object ( int64_t id )

inline

Definition at line 2852 of file ThriftBroker.cc.

void Hypertable::ThriftBroker::ServerHandler::remove_future ( int64_t id )

inline

Definition at line 2978 of file ThriftBroker.cc.

void Hypertable::ThriftBroker::ServerHandler::remove_mutator ( int64_t id )

inline

Definition at line 2994 of file ThriftBroker.cc.

void Hypertable::ThriftBroker::ServerHandler::remove_namespace ( int64_t id )

inline

Definition at line 2986 of file ThriftBroker.cc.

bool Hypertable::ThriftBroker::ServerHandler::remove_object ( int64_t id )

inline

Definition at line 2836 of file ThriftBroker.cc.

void Hypertable::ThriftBroker::ServerHandler::remove_references ( int64_t id )

inline

Definition at line 2804 of file ThriftBroker.cc.

void Hypertable::ThriftBroker::ServerHandler::remove_scanner ( int64_t id )

inline

Definition at line 2868 of file ThriftBroker.cc.

void Hypertable::ThriftBroker::ServerHandler::remove_scanner	(	int64_t	id,
		ClientObjectPtr &	scanner,
		ScannerInfoPtr &	info
	)

inline

Definition at line 2887 of file ThriftBroker.cc.

void Hypertable::ThriftBroker::ServerHandler::rename_table	(	const ThriftGen::Namespace	ns,
		const String &	table,
		const String &	new_table_name
	)

inlineoverride

Definition at line 2428 of file ThriftBroker.cc.

void Hypertable::ThriftBroker::ServerHandler::run_hql_interp	(	const ThriftGen::Namespace	ns,
		const String &	hql,
		HqlInterpreter::Callback &	cb
	)

inline

Definition at line 2656 of file ThriftBroker.cc.

void Hypertable::ThriftBroker::ServerHandler::scanner_close ( const Scanner id )

inlineoverride

Definition at line 1296 of file ThriftBroker.cc.

void Hypertable::ThriftBroker::ServerHandler::scanner_get_cells	(	ThriftCells &	result,
		const Scanner	scanner_id
	)

inlineoverride

Definition at line 1356 of file ThriftBroker.cc.

void Hypertable::ThriftBroker::ServerHandler::scanner_get_cells_as_arrays	(	ThriftCellsAsArrays &	result,
		const Scanner	scanner_id
	)

inlineoverride

Definition at line 1370 of file ThriftBroker.cc.

void Hypertable::ThriftBroker::ServerHandler::scanner_get_cells_serialized	(	CellsSerialized &	result,
		const Scanner	scanner_id
	)

inlineoverride

Definition at line 1385 of file ThriftBroker.cc.

void Hypertable::ThriftBroker::ServerHandler::scanner_get_row	(	ThriftCells &	result,
		const Scanner	scanner_id
	)

inlineoverride

Definition at line 1419 of file ThriftBroker.cc.

void Hypertable::ThriftBroker::ServerHandler::scanner_get_row_as_arrays	(	ThriftCellsAsArrays &	result,
		const Scanner	scanner_id
	)

inlineoverride

Definition at line 1433 of file ThriftBroker.cc.

void Hypertable::ThriftBroker::ServerHandler::scanner_get_row_serialized	(	CellsSerialized &	result,
		const Scanner	scanner_id
	)

inlineoverride

Definition at line 1448 of file ThriftBroker.cc.

Scanner Hypertable::ThriftBroker::ServerHandler::scanner_open	(	const ThriftGen::Namespace	ns,
		const String &	table,
		const ThriftGen::ScanSpec &	ss
	)

inlineoverride

Definition at line 1234 of file ThriftBroker.cc.

void Hypertable::ThriftBroker::ServerHandler::set_cell	(	const ThriftGen::Namespace	ns,
		const String &	table,
		const ThriftGen::Cell &	cell
	)

inlineoverride

Definition at line 2070 of file ThriftBroker.cc.

void Hypertable::ThriftBroker::ServerHandler::set_cell_as_array	(	const ThriftGen::Namespace	ns,
		const String &	table,
		const CellAsArray &	cell
	)

inlineoverride

Definition at line 2115 of file ThriftBroker.cc.

void Hypertable::ThriftBroker::ServerHandler::set_cell_as_array_async	(	const MutatorAsync	mutator,
		const CellAsArray &	cell
	)

inlineoverride

Definition at line 2209 of file ThriftBroker.cc.

void Hypertable::ThriftBroker::ServerHandler::set_cell_async	(	const MutatorAsync	mutator,
		const ThriftGen::Cell &	cell
	)

inlineoverride

Definition at line 2179 of file ThriftBroker.cc.

void Hypertable::ThriftBroker::ServerHandler::set_cells	(	const ThriftGen::Namespace	ns,
		const String &	table,
		const ThriftCells &	cells
	)

inlineoverride

Definition at line 2085 of file ThriftBroker.cc.

void Hypertable::ThriftBroker::ServerHandler::set_cells_as_arrays	(	const ThriftGen::Namespace	ns,
		const String &	table,
		const ThriftCellsAsArrays &	cells
	)

inlineoverride

Definition at line 2100 of file ThriftBroker.cc.

void Hypertable::ThriftBroker::ServerHandler::set_cells_as_arrays_async	(	const MutatorAsync	mutator,
		const ThriftCellsAsArrays &	cells
	)

inlineoverride

Definition at line 2193 of file ThriftBroker.cc.

void Hypertable::ThriftBroker::ServerHandler::set_cells_async	(	const MutatorAsync	mutator,
		const ThriftCells &	cells
	)

inlineoverride

Definition at line 2165 of file ThriftBroker.cc.

void Hypertable::ThriftBroker::ServerHandler::set_cells_serialized	(	const ThriftGen::Namespace	ns,
		const String &	table,
		const CellsSerialized &	cells
	)

inlineoverride

Definition at line 2134 of file ThriftBroker.cc.

void Hypertable::ThriftBroker::ServerHandler::set_cells_serialized_async	(	const MutatorAsync	mutator,
		const CellsSerialized &	cells,
		const bool	flush
	)

inlineoverride

Definition at line 2236 of file ThriftBroker.cc.

void Hypertable::ThriftBroker::ServerHandler::shared_mutator_refresh	(	const ThriftGen::Namespace	ns,
		const String &	table,
		const ThriftGen::MutateSpec &	mutate_spec
	)

inlineoverride

Definition at line 2903 of file ThriftBroker.cc.

void Hypertable::ThriftBroker::ServerHandler::shared_mutator_set_cell	(	const ThriftGen::Namespace	ns,
		const String &	table,
		const ThriftGen::MutateSpec &	mutate_spec,
		const ThriftGen::Cell &	cell
	)

inlineoverride

Definition at line 1655 of file ThriftBroker.cc.

void Hypertable::ThriftBroker::ServerHandler::shared_mutator_set_cell_as_array	(	const ThriftGen::Namespace	ns,
		const String &	table,
		const ThriftGen::MutateSpec &	mutate_spec,
		const CellAsArray &	cell
	)

inlineoverride

Definition at line 1693 of file ThriftBroker.cc.

void Hypertable::ThriftBroker::ServerHandler::shared_mutator_set_cells	(	const ThriftGen::Namespace	ns,
		const String &	table,
		const ThriftGen::MutateSpec &	mutate_spec,
		const ThriftCells &	cells
	)

inlineoverride

Definition at line 1637 of file ThriftBroker.cc.

void Hypertable::ThriftBroker::ServerHandler::shared_mutator_set_cells_as_arrays	(	const ThriftGen::Namespace	ns,
		const String &	table,
		const ThriftGen::MutateSpec &	mutate_spec,
		const ThriftCellsAsArrays &	cells
	)

inlineoverride

Definition at line 1674 of file ThriftBroker.cc.

void Hypertable::ThriftBroker::ServerHandler::shutdown ( )

inlineoverride

Definition at line 2488 of file ThriftBroker.cc.

void Hypertable::ThriftBroker::ServerHandler::status ( ThriftGen::Status & _return )

inlineoverride

Definition at line 2480 of file ThriftBroker.cc.

void Hypertable::ThriftBroker::ServerHandler::table_alter	(	const ThriftGen::Namespace	ns,
		const String &	table,
		const ThriftGen::Schema &	schema
	)

inlineoverride

Definition at line 1220 of file ThriftBroker.cc.

void Hypertable::ThriftBroker::ServerHandler::table_create	(	const ThriftGen::Namespace	ns,
		const String &	table,
		const ThriftGen::Schema &	schema
	)

inlineoverride

Definition at line 1206 of file ThriftBroker.cc.

void Hypertable::ThriftBroker::ServerHandler::table_drop	(	const ThriftGen::Namespace	ns,
		const String &	table,
		const bool	if_exists
	)

inlineoverride

Definition at line 2433 of file ThriftBroker.cc.

bool Hypertable::ThriftBroker::ServerHandler::table_exists	(	const ThriftGen::Namespace	ns,
		const String &	table
	)

inlineoverride

Definition at line 2256 of file ThriftBroker.cc.

void Hypertable::ThriftBroker::ServerHandler::table_get_id	(	String &	result,
		const ThriftGen::Namespace	ns,
		const String &	table
	)

inlineoverride

Definition at line 2273 of file ThriftBroker.cc.

void Hypertable::ThriftBroker::ServerHandler::table_get_schema	(	ThriftGen::Schema &	result,
		const ThriftGen::Namespace	ns,
		const String &	table
	)

inlineoverride

Definition at line 2318 of file ThriftBroker.cc.

void Hypertable::ThriftBroker::ServerHandler::table_get_schema_str	(	String &	result,
		const ThriftGen::Namespace	ns,
		const String &	table
	)

inlineoverride

Definition at line 2288 of file ThriftBroker.cc.

void Hypertable::ThriftBroker::ServerHandler::table_get_schema_str_with_ids	(	String &	result,
		const ThriftGen::Namespace	ns,
		const String &	table
	)

inlineoverride

Definition at line 2303 of file ThriftBroker.cc.

void Hypertable::ThriftBroker::ServerHandler::table_get_splits	(	std::vector< ThriftGen::TableSplit > &	_return,
		const ThriftGen::Namespace	ns,
		const String &	table
	)

inlineoverride

Definition at line 2377 of file ThriftBroker.cc.

void Hypertable::ThriftBroker::ServerHandler::table_rename	(	const ThriftGen::Namespace	ns,
		const String &	table,
		const String &	new_table_name
	)

inlineoverride

Definition at line 2415 of file ThriftBroker.cc.

int64_t Hypertable::ThriftBroker::ServerHandler::try_get_object_id ( ClientObject * co )

inline

Definition at line 2775 of file ThriftBroker.cc.

Member Data Documentation

ObjectMap Hypertable::ThriftBroker::ServerHandler::m_cached_object_map

private

Definition at line 3008 of file ThriftBroker.cc.

Context& Hypertable::ThriftBroker::ServerHandler::m_context

private

Definition at line 3004 of file ThriftBroker.cc.

std::mutex Hypertable::ThriftBroker::ServerHandler::m_mutex

private

Definition at line 3005 of file ThriftBroker.cc.

ObjectMap Hypertable::ThriftBroker::ServerHandler::m_object_map

private

Definition at line 3007 of file ThriftBroker.cc.

multimap<::int64_t, ClientObjectPtr> Hypertable::ThriftBroker::ServerHandler::m_reference_map

private

Definition at line 3006 of file ThriftBroker.cc.

String Hypertable::ThriftBroker::ServerHandler::m_remote_peer

private

Definition at line 3003 of file ThriftBroker.cc.

std::unordered_map< ::int64_t, ScannerInfoPtr> Hypertable::ThriftBroker::ServerHandler::m_scanner_info_map

private

Definition at line 3009 of file ThriftBroker.cc.

The documentation for this class was generated from the following file:

/home/doug/src/hypertable/src/cc/ThriftBroker/ThriftBroker.cc

Classes

Public Member Functions

Private Attributes

Detailed Description

Constructor & Destructor Documentation

Member Function Documentation

Member Data Documentation