mutation callback
(raw_mu)
| 11 | |
| 12 | |
| 13 | def mutation_callback(raw_mu): |
| 14 | """ mutation callback """ |
| 15 | mu = RowMutation(raw_mu) |
| 16 | status = mu.GetStatus() |
| 17 | if status.GetReasonNumber() != Status.OK: |
| 18 | print(status.GetReasonString()) |
| 19 | print "callback of rowkey:", mu.RowKey() |
| 20 | mu.Destroy() |
| 21 | """ 用户需要确保回调执行时,write_callback仍然有效(例如没有因为过作用域被gc掉)""" |
| 22 | write_callback = MUTATION_CALLBACK(mutation_callback) |
| 23 |
nothing calls this directly
no test coverage detected