Synchronous table scanner.
More...
#include <TableScanner.h>
Synchronous table scanner.
Definition at line 39 of file TableScanner.h.
Constructor.
- Parameters
-
comm | Comm layer object |
table | Table object |
range_locator | Smart pointer to range locator |
scan_spec | Scan specification |
timeout_ms | Timeout (deadline) milliseconds |
Definition at line 35 of file TableScanner.cc.
virtual Hypertable::TableScanner::~TableScanner |
( |
| ) |
|
|
inlinevirtual |
Destructor.
Cancel asynchronous scanner and keep dealing with RangeServer responses till async scanner is finished.
Definition at line 57 of file TableScanner.h.
Gets profile data.
- Parameters
-
profile_data | Reference to profile data object populated by this method |
Definition at line 91 of file TableScanner.h.
bool TableScanner::next |
( |
Cell & |
cell | ) |
|
Gets the next cell.
- Parameters
-
cell | The cell object to contain the result |
- Returns
- true on success, false on end of scan
Definition at line 49 of file TableScanner.cc.
void TableScanner::scan_error |
( |
int |
error, |
|
|
const std::string & |
error_msg |
|
) |
| |
|
private |
Callback for successful scan.
- Parameters
-
cells | Vector of returned cells |
Definition at line 94 of file TableScanner.cc.
void TableScanner::unget |
( |
const Cell & |
cell | ) |
|
Ungets one cell.
Only one cell that's previously obtained from next can be unget. Mostly designed to provide one cell look-ahead for downstream wrapper to implement next_row.
- Parameters
-
cell | the cell object to unget |
- Exceptions
-
exception | if unget is called twice without intervening next |
Definition at line 87 of file TableScanner.cc.
size_t Hypertable::TableScanner::m_cur_cells_index |
|
private |
size_t Hypertable::TableScanner::m_cur_cells_size |
|
private |
bool Hypertable::TableScanner::m_eos |
|
private |
int Hypertable::TableScanner::m_error |
|
private |
std::string Hypertable::TableScanner::m_error_msg |
|
private |
Cell Hypertable::TableScanner::m_ungot |
|
private |
The documentation for this class was generated from the following files: