reader callback
(raw_reader)
| 23 | |
| 24 | |
| 25 | def reader_callback(raw_reader): |
| 26 | """ reader callback """ |
| 27 | reader = RowReader(raw_reader) |
| 28 | status = reader.GetStatus() |
| 29 | if status.GetReasonNumber() != Status.OK: |
| 30 | print(status.GetReasonString()) |
| 31 | while not reader.Done(): |
| 32 | row = reader.RowKey() |
| 33 | column = reader.Family() + ":" + reader.Qualifier() |
| 34 | timestamp = str(reader.Timestamp()) |
| 35 | val = reader.Value() |
| 36 | print row + ":" + column + ":" + timestamp + ":" + val |
| 37 | reader.Next() |
| 38 | reader.Destroy() |
| 39 | |
| 40 | """ 用户需要确保回调执行时，read_callback仍然有效（例如没有因为过作用域被gc掉）""" |
| 41 | read_callback = READER_CALLBACK(reader_callback) |
nothing calls this directly
no test coverage detected