Store data in the hbase table. Arguments: table_name: Name of the Hbase table. row_key: Row key of the row to be inserted to hbase table. data: Mapping of column family name:column name to column values
(self, table_name: str, row_key: str, data: dict)
| 100 | return conn.table(table_name).batch() |
| 101 | |
| 102 | def put(self, table_name: str, row_key: str, data: dict): |
| 103 | """ |
| 104 | Store data in the hbase table. |
| 105 | |
| 106 | Arguments: |
| 107 | table_name: Name of the Hbase table. |
| 108 | row_key: Row key of the row to be inserted to hbase table. |
| 109 | data: Mapping of column family name:column name to column values |
| 110 | """ |
| 111 | with self.pool.connection() as conn: |
| 112 | table = conn.table(table_name) |
| 113 | table.put(row_key, data) |
| 114 | |
| 115 | def row( |
| 116 | self, |