Represents an open table. More...
#include <TableCallback.h>
Public Member Functions | |
TableCallback (TableScanner *scanner) | |
TableCallback (TableMutator *mutator) | |
void | scan_ok (TableScannerAsync *scanner, ScanCellsPtr &cells) |
Callback method for successful scan. More... | |
void | scan_error (TableScannerAsync *scanner, int error, const std::string &error_msg, bool eos) |
Callback method for scan errors. More... | |
void | update_ok (TableMutatorAsync *mutator) |
Callback method for successful mutations. More... | |
void | update_error (TableMutatorAsync *mutator, int error, FailedMutations &failures) |
Callback method for mutation errors. More... | |
Public Member Functions inherited from Hypertable::ResultCallback | |
ResultCallback () | |
virtual | ~ResultCallback () |
virtual void | register_scanner (TableScannerAsync *scanner) |
Hook for derived classes which want to keep track of scanners/mutators. More... | |
virtual void | deregister_scanner (TableScannerAsync *scanner) |
Hook for derived classes which want to keep track of scanners/mutators. More... | |
virtual void | register_mutator (TableMutatorAsync *mutator) |
Hook for derived classes which want to keep track of scanners/mutators. More... | |
virtual void | deregister_mutator (TableMutatorAsync *mutator) |
Hook for derived classes which want to keep track of scanners/mutators. More... | |
virtual void | completed () |
Callback method for completion, default one does nothing. More... | |
void | wait_for_completion () |
Blocks till outstanding == 0. More... | |
void | increment_outstanding () |
void | decrement_outstanding () |
bool | is_done () |
Public Member Functions inherited from Hypertable::ClientObject | |
virtual | ~ClientObject () |
Destructor. More... | |
Private Attributes | |
TableScanner * | m_scanner |
TableMutator * | m_mutator |
Additional Inherited Members | |
Protected Attributes inherited from Hypertable::ResultCallback | |
int | m_outstanding {} |
std::mutex | m_outstanding_mutex |
std::condition_variable | m_outstanding_cond |
Represents an open table.
Definition at line 34 of file TableCallback.h.
|
inline |
Definition at line 38 of file TableCallback.h.
|
inline |
Definition at line 39 of file TableCallback.h.
|
virtual |
Callback method for scan errors.
scanner | |
error | |
error_msg | |
eos | end of scan |
Implements Hypertable::ResultCallback.
Definition at line 34 of file TableCallback.cc.
|
virtual |
Callback method for successful scan.
scanner | |
cells | returned cells |
Implements Hypertable::ResultCallback.
Definition at line 30 of file TableCallback.cc.
|
virtual |
Callback method for mutation errors.
mutator | |
error | |
failures | vector of failed mutations |
Implements Hypertable::ResultCallback.
Definition at line 43 of file TableCallback.cc.
|
virtual |
Callback method for successful mutations.
mutator |
Implements Hypertable::ResultCallback.
Definition at line 39 of file TableCallback.cc.
|
private |
Definition at line 78 of file TableCallback.h.
|
private |
Definition at line 77 of file TableCallback.h.