Returns an iterable of batches of result rows. Each batch is an iterable of rows. Each row is an iterable of strings in the format in which they should be displayed Tries to ensure that the batches have a granularity of self.fetch_size but does not guarantee it.
(self, query_handle)
| 347 | raise NotImplementedError() |
| 348 | |
| 349 | def fetch(self, query_handle): |
| 350 | """Returns an iterable of batches of result rows. Each batch is an iterable of rows. |
| 351 | Each row is an iterable of strings in the format in which they should be displayed |
| 352 | Tries to ensure that the batches have a granularity of self.fetch_size but |
| 353 | does not guarantee it. |
| 354 | """ |
| 355 | """Returns an iterable of batches of result rows up to self.fetch_size. Does |
| 356 | not need to consolidate those batches into larger batches.""" |
| 357 | raise NotImplementedError() |
| 358 | |
| 359 | # TODO: when we remove Beeswax, we could merge close_dml() and close_query() |
| 360 | # because the CloseImpalaOperation() response contains enough information to |
no outgoing calls
no test coverage detected