(self, query_handle)
| 1369 | return state |
| 1370 | |
| 1371 | def fetch(self, query_handle): |
| 1372 | while True: |
| 1373 | result, rpc_status = self._do_beeswax_rpc( |
| 1374 | lambda: self.imp_service.fetch(query_handle, False, |
| 1375 | self.fetch_size)) |
| 1376 | if rpc_status != RpcStatus.OK: |
| 1377 | raise RPCException() |
| 1378 | |
| 1379 | def split_row_and_decode_if_needed(row): |
| 1380 | # Decode before splitting as this can remove incidental tabs from |
| 1381 | # multibyte characters. |
| 1382 | return utf8_decode_if_needed(row).split('\t') |
| 1383 | |
| 1384 | yield [split_row_and_decode_if_needed(row) for row in result.data] |
| 1385 | |
| 1386 | if not result.has_more: |
| 1387 | return |
| 1388 | |
| 1389 | def close_dml(self, last_query_handle): |
| 1390 | dml_result, rpc_status = self._do_beeswax_rpc( |
nothing calls this directly
no test coverage detected