Prints the table scanning all the rows of the hbase table.
(self, table_name)
| 157 | return table.rows(row_keys, columns, timestamp, include_timestamp) |
| 158 | |
| 159 | def print_table(self, table_name): |
| 160 | """Prints the table scanning all the rows of the hbase table.""" |
| 161 | with self.pool.connection() as conn: |
| 162 | table = conn.table(table_name) |
| 163 | scan_data = table.scan() |
| 164 | for row_key, cols in scan_data: |
| 165 | print(row_key.decode("utf-8"), cols) |
| 166 | |
| 167 | def delete_table(self, table: str): |
| 168 | """Deletes the hbase table given the table name.""" |