| 572 | } |
| 573 | |
| 574 | void Result::ProcessAssignments(const AssignmentCallback& cb) const { |
| 575 | for (const FragmentScanRangeAssignment& assignment : assignments_) { |
| 576 | for (const auto& assignment_elem : assignment) { |
| 577 | const NetworkAddressPB& addr = assignment_elem.first; |
| 578 | const PerNodeScanRanges& per_node_ranges = assignment_elem.second; |
| 579 | for (const auto& per_node_ranges_elem : per_node_ranges) { |
| 580 | const vector<ScanRangeParamsPB> scan_range_params_vector = |
| 581 | per_node_ranges_elem.second; |
| 582 | for (const ScanRangeParamsPB& scan_range_params : scan_range_params_vector) { |
| 583 | const ScanRangePB& scan_range = scan_range_params.scan_range(); |
| 584 | HdfsFileSplitPB hdfs_file_split; |
| 585 | if (scan_range.has_hdfs_file_split()) { |
| 586 | hdfs_file_split = scan_range.hdfs_file_split(); |
| 587 | } else { |
| 588 | DCHECK(scan_range.has_is_system_scan() && scan_range.is_system_scan()); |
| 589 | hdfs_file_split.set_length(0); |
| 590 | } |
| 591 | bool try_hdfs_cache = scan_range_params.has_try_hdfs_cache() ? |
| 592 | scan_range_params.try_hdfs_cache() : false; |
| 593 | bool is_remote = |
| 594 | scan_range_params.has_is_remote() ? scan_range_params.is_remote() : false; |
| 595 | cb({addr, hdfs_file_split, try_hdfs_cache, is_remote}); |
| 596 | } |
| 597 | } |
| 598 | } |
| 599 | } |
| 600 | } |
| 601 | |
| 602 | int Result::CountAssignmentsIf(const AssignmentFilter& filter) const { |
| 603 | int count = 0; |
nothing calls this directly
no test coverage detected