| 343 | } |
| 344 | |
| 345 | void ScanNode::ScannerThreadState::EnqueueBatch( |
| 346 | unique_ptr<RowBatch> row_batch) { |
| 347 | // Only need to count tuple_data_pool() bytes since after IMPALA-5307, no buffers are |
| 348 | // returned from the scan node. |
| 349 | int64_t bytes = row_batch->tuple_data_pool()->total_reserved_bytes(); |
| 350 | row_batch->SetMemTracker(row_batches_mem_tracker_); |
| 351 | batch_queue_->AddBatch(move(row_batch)); |
| 352 | COUNTER_ADD(row_batches_enqueued_, 1); |
| 353 | COUNTER_ADD(row_batch_bytes_enqueued_, bytes); |
| 354 | } |
| 355 | |
| 356 | bool ScanNode::ScannerThreadState::EnqueueBatchWithTimeout( |
| 357 | unique_ptr<RowBatch>* row_batch, int64_t timeout_micros) { |
no test coverage detected