| 2431 | } |
| 2432 | |
| 2433 | compute::Expression Materialize(std::vector<std::string> names, |
| 2434 | bool include_aug_fields = false) { |
| 2435 | if (include_aug_fields) { |
| 2436 | for (auto aug_name : |
| 2437 | {"__fragment_index", "__batch_index", "__last_in_fragment", "__filename"}) { |
| 2438 | names.emplace_back(aug_name); |
| 2439 | } |
| 2440 | } |
| 2441 | |
| 2442 | std::vector<compute::Expression> exprs; |
| 2443 | for (const auto& name : names) { |
| 2444 | exprs.push_back(field_ref(name)); |
| 2445 | } |
| 2446 | |
| 2447 | return project(exprs, names); |
| 2448 | } |
| 2449 | } // namespace |
| 2450 | |
| 2451 | TEST(ScanNode, Schema) { |
no test coverage detected