MCPcopy Create free account
hub / github.com/apache/impala / EnqueueScanRange

Method EnqueueScanRange

be/src/exec/hdfs-scan-node-base.cc:1386–1390  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

1384}
1385
1386void ScanRangeSharedState::EnqueueScanRange(
1387 const vector<ScanRange*>& ranges, bool at_front) {
1388 DCHECK(use_mt_scan_node_) << "Should only be called by MT scan nodes";
1389 scan_range_queue_.EnqueueRanges(ranges, at_front);
1390}
1391
1392Status ScanRangeSharedState::GetNextScanRange(
1393 RuntimeState* state, ScanRange** scan_range) {

Callers 1

AddDiskIoRangesMethod · 0.80

Calls 1

EnqueueRangesMethod · 0.80

Tested by

no test coverage detected