class Batch:
hbspark.table.Table.| Method | __init__ |
Creates a new batch processor for a hbspark.table.Table instance. |
| Method | delete |
Load a new delete operation into the batch. |
| Method | put |
Load a new put operation into the batch. |
| Method | send |
Send all of the pending changes loaded into the batch process. |
| Instance Variable | _hb_batch |
The corresponding Happybase batch processesor. |
Creates a new batch processor for a hbspark.table.Table instance.
Should only be initialized through hbspark.table.Table.batch and not called by the user separately.
| Parameters | |
| hb_batch:happybase.Batch | The happybase batch link that allows batch operations on the current table. |
| Returns | |
hbspark.table.Table.Batch | A new instance of the batch processor. |
Load a new delete operation into the batch.
The column payload should have the following structure:
column = ["cf_x:col_x", ...]
| Parameters | |
| rowkey:string | The rowkey targeting the row to be deleted. |
| column:list | The list of column names to be deleted. |
| wal:bool | Whether or not to insert into the WAL for HBase. |
| Returns | |
| None | Method does not return. |
Load a new put operation into the batch.
The data payload should have the following structure:
data = {
"cf_x:col_x" : "value",
...
}
| Parameters | |
| rowkey:string | The rowkey for the new inserted row. |
| data:dict | The dictionary mapping cf:col to values to be stored. |
| wal:bool | Whether or not to write to the WAL of HBase. |
| Returns | |
| None | Method does not return. |