| 198 | } |
| 199 | |
| 200 | void HdfsScanNode::AddMaterializedRowBatch(unique_ptr<RowBatch> row_batch) { |
| 201 | InitNullCollectionValues(row_batch.get()); |
| 202 | thread_state_.EnqueueBatch(move(row_batch)); |
| 203 | } |
| 204 | |
| 205 | Status HdfsScanNode::AddDiskIoRanges(const vector<ScanRange*>& ranges, |
| 206 | EnqueueLocation enqueue_location) { |
no test coverage detected