buffer_finish(uint32_t id, int error, bool retry) | Hypertable::TableMutatorAsync | |
cancel() | Hypertable::TableMutatorAsync | |
do_sync() | Hypertable::TableMutatorAsync | private |
FLUSH enum value | Hypertable::TableMutatorAsync | private |
flush(bool sync=true) | Hypertable::TableMutatorAsync | |
flush_with_tablequeue(TableMutator *mutator, bool sync=true) | Hypertable::TableMutatorAsync | private |
get_failed_mutations(FailedMutations &failed_mutations) | Hypertable::TableMutatorAsync | inline |
get_outstanding_buffer(size_t id) | Hypertable::TableMutatorAsync | |
get_resend_count() | Hypertable::TableMutatorAsync | inline |
get_unsynced_rangeservers(std::vector< CommAddress > &unsynced) | Hypertable::TableMutatorAsync | |
handle_send_exceptions(const String &info) | Hypertable::TableMutatorAsync | private |
has_outstanding() | Hypertable::TableMutatorAsync | inline |
has_outstanding_unlocked() | Hypertable::TableMutatorAsync | inline |
IndexMutatorCallback class | Hypertable::TableMutatorAsync | friend |
initialize(PropertiesPtr &props) | Hypertable::TableMutatorAsync | private |
initialize_indices(PropertiesPtr &props) | Hypertable::TableMutatorAsync | private |
is_cancelled() | Hypertable::TableMutatorAsync | |
key_uses_index(Key &key) | Hypertable::TableMutatorAsync | private |
m_app_queue | Hypertable::TableMutatorAsync | private |
m_buffer_cond | Hypertable::TableMutatorAsync | private |
m_buffer_mutex | Hypertable::TableMutatorAsync | private |
m_cancelled | Hypertable::TableMutatorAsync | private |
m_cb | Hypertable::TableMutatorAsync | private |
m_comm | Hypertable::TableMutatorAsync | private |
m_cond | Hypertable::TableMutatorAsync | private |
m_current_buffer | Hypertable::TableMutatorAsync | private |
m_explicit_block_only | Hypertable::TableMutatorAsync | private |
m_failed_mutations | Hypertable::TableMutatorAsync | private |
m_flags | Hypertable::TableMutatorAsync | private |
m_imc | Hypertable::TableMutatorAsync | private |
m_index_mutator | Hypertable::TableMutatorAsync | private |
m_max_memory | Hypertable::TableMutatorAsync | private |
m_member_mutex | Hypertable::TableMutatorAsync | private |
m_memory_used | Hypertable::TableMutatorAsync | private |
m_mutated | Hypertable::TableMutatorAsync | private |
m_mutator | Hypertable::TableMutatorAsync | private |
m_mutex | Hypertable::TableMutatorAsync | private |
m_next_buffer_id | Hypertable::TableMutatorAsync | private |
m_outstanding_buffers | Hypertable::TableMutatorAsync | private |
m_props | Hypertable::TableMutatorAsync | private |
m_qualifier_index_mutator | Hypertable::TableMutatorAsync | private |
m_range_locator | Hypertable::TableMutatorAsync | private |
m_resends | Hypertable::TableMutatorAsync | private |
m_schema | Hypertable::TableMutatorAsync | private |
m_table | Hypertable::TableMutatorAsync | private |
m_table_identifier | Hypertable::TableMutatorAsync | private |
m_timeout_ms | Hypertable::TableMutatorAsync | private |
m_unsynced_rangeservers | Hypertable::TableMutatorAsync | private |
m_use_index | Hypertable::TableMutatorAsync | private |
memory_used() | Hypertable::TableMutatorAsync | inlinevirtual |
ms_max_sync_retries | Hypertable::TableMutatorAsync | privatestatic |
mutated() | Hypertable::TableMutatorAsync | inlineprivate |
needs_flush() | Hypertable::TableMutatorAsync | |
Operation enum name | Hypertable::TableMutatorAsync | private |
retry(uint32_t timeout_ms) | Hypertable::TableMutatorAsync | |
ScatterBufferAsyncMap typedef | Hypertable::TableMutatorAsync | private |
schema() | Hypertable::TableMutatorAsync | inline |
set(const KeySpec &key, const void *value, uint32_t value_len) | Hypertable::TableMutatorAsync | |
set(const KeySpec &key, const char *value) | Hypertable::TableMutatorAsync | inline |
set(const KeySpec &key, const std::string &value) | Hypertable::TableMutatorAsync | inline |
SET enum value | Hypertable::TableMutatorAsync | private |
SET_CELLS enum value | Hypertable::TableMutatorAsync | private |
set_cells(const Cells &cells) | Hypertable::TableMutatorAsync | inline |
set_cells(Cells::const_iterator start, Cells::const_iterator end) | Hypertable::TableMutatorAsync | |
set_delete(const KeySpec &key) | Hypertable::TableMutatorAsync | |
SET_DELETE enum value | Hypertable::TableMutatorAsync | private |
TableMutator class | Hypertable::TableMutatorAsync | friend |
TableMutatorAsync(PropertiesPtr &props, Comm *comm, ApplicationQueueInterfacePtr &app_queue, Table *table, RangeLocatorPtr &range_locator, uint32_t timeout_ms, ResultCallback *cb, uint32_t flags=0, bool explicit_block_only=false) | Hypertable::TableMutatorAsync | |
TableMutatorAsync(std::mutex &mutex, std::condition_variable &cond, PropertiesPtr &props, Comm *comm, ApplicationQueueInterfacePtr &app_queue, Table *table, RangeLocatorPtr &range_locator, uint32_t timeout_ms, ResultCallback *cb, uint32_t flags=0, bool explicit_block_only=false, TableMutator *mutator=0) | Hypertable::TableMutatorAsync | |
to_full_key(const void *row, const char *cf, const void *cq, int64_t ts, int64_t rev, uint8_t flag, Key &full_key, ColumnFamilySpec **pcf=0) | Hypertable::TableMutatorAsync | private |
to_full_key(const KeySpec &key, Key &full_key, ColumnFamilySpec **cf=0) | Hypertable::TableMutatorAsync | inlineprivate |
to_full_key(const Cell &cell, Key &full_key, ColumnFamilySpec **cf=0) | Hypertable::TableMutatorAsync | inlineprivate |
update_outstanding(TableMutatorAsyncScatterBufferPtr &buffer) | Hypertable::TableMutatorAsync | |
update_unsynced_rangeservers(const CommAddressSet &unsynced) | Hypertable::TableMutatorAsync | private |
update_with_index(Key &key, const ColumnFamilySpec *cf, const void *value, uint32_t value_len) | Hypertable::TableMutatorAsync | private |
update_without_index(const Cell &cell) | Hypertable::TableMutatorAsync | private |
update_without_index(const Key &full_key, const ColumnFamilySpec *cf, const Cell &cell) | Hypertable::TableMutatorAsync | private |
update_without_index(const Key &full_key, const ColumnFamilySpec *cf, const void *value, size_t value_len) | Hypertable::TableMutatorAsync | private |
wait_for_completion() | Hypertable::TableMutatorAsync | protected |
~ClientObject() | Hypertable::ClientObject | inlinevirtual |
~TableMutatorAsync() | Hypertable::TableMutatorAsync | virtual |