| 1045 | } |
| 1046 | |
| 1047 | ScanRange* HdfsScanner::FindFooterSplit(HdfsFileDesc* file) { |
| 1048 | DCHECK(file != nullptr); |
| 1049 | for (int i = 0; i < file->splits.size(); ++i) { |
| 1050 | ScanRange* split = file->splits[i]; |
| 1051 | if (split->offset() + split->len() == file->file_length) return split; |
| 1052 | } |
| 1053 | return nullptr; |
| 1054 | } |
| 1055 | |
| 1056 | bool HdfsScanner::EvalRuntimeFilters(TupleRow* row) { |
| 1057 | int num_filters = filter_ctxs_.size(); |