| 1422 | } |
| 1423 | |
| 1424 | Status ClientRequestState::FetchRows(const int32_t max_rows, |
| 1425 | QueryResultSet* fetched_rows, int64_t block_on_wait_time_us) { |
| 1426 | // Pause the wait timer, since the client has instructed us to do work on its behalf. |
| 1427 | MarkActive(); |
| 1428 | |
| 1429 | // ImpalaServer::FetchInternal has already taken our lock_ |
| 1430 | discard_result(UpdateQueryStatus( |
| 1431 | FetchRowsInternal(max_rows, fetched_rows, block_on_wait_time_us))); |
| 1432 | |
| 1433 | MarkInactive(); |
| 1434 | return query_status_; |
| 1435 | } |
| 1436 | |
| 1437 | Status ClientRequestState::RestartFetch() { |
| 1438 | // No result caching for this query. Restart is invalid. |
no test coverage detected