设置回调 调用此函数则本次随机读为异步(Table.ApplyReader()立即返回); 否则本次随机读为同步(Table.ApplyReader()等待读取操作完成后返回) 可以在回调中执行 Done() 和 Next() 对返回的结果进行迭代处理 Args: callback(READER_CALLBACK): 用户回调,不论任何情况,最终都会被调用
(self, callback)
| 705 | lib.tera_row_reader_add_column(self.reader, cf, qu, c_uint64(len(qu))) |
| 706 | |
| 707 | def SetCallback(self, callback): |
| 708 | """ 设置回调 |
| 709 | 调用此函数则本次随机读为异步(Table.ApplyReader()立即返回); |
| 710 | 否则本次随机读为同步(Table.ApplyReader()等待读取操作完成后返回) |
| 711 | |
| 712 | 可以在回调中执行 Done() 和 Next() 对返回的结果进行迭代处理 |
| 713 | |
| 714 | Args: |
| 715 | callback(READER_CALLBACK): 用户回调,不论任何情况,最终都会被调用 |
| 716 | """ |
| 717 | lib.tera_row_reader_set_callback(self.reader, callback) |
| 718 | |
| 719 | def SetTimestamp(self, ts): |
| 720 | """ set timestamp """ |