async put
(table)
| 154 | |
| 155 | |
| 156 | def async_put(table): |
| 157 | """ async put """ |
| 158 | print("\nasync put") |
| 159 | rowkey_list = ["async"] |
| 160 | for key in rowkey_list: |
| 161 | mu = table.NewRowMutation(key) |
| 162 | mu.Put("cf0", "qu0", "value") |
| 163 | mu.SetCallback(write_callback) |
| 164 | table.ApplyMutation(mu) |
| 165 | while not table.IsPutFinished(): |
| 166 | time.sleep(0.01) |
| 167 | |
| 168 | |
| 169 | def async_get(table): |
no test coverage detected