| 371 | |
| 372 | protected: |
| 373 | void SetSchema(std::vector<std::shared_ptr<Field>> fields) { |
| 374 | schema_ = schema(std::move(fields)); |
| 375 | options_ = std::make_shared<ScanOptions>(); |
| 376 | options_->dataset_schema = schema_; |
| 377 | ASSERT_OK_AND_ASSIGN(auto projection, |
| 378 | ProjectionDescr::FromNames(schema_->field_names(), *schema_, |
| 379 | options_->add_augmented_fields)); |
| 380 | SetProjection(options_.get(), std::move(projection)); |
| 381 | SetFilter(literal(true)); |
| 382 | } |
| 383 | |
| 384 | void SetFilter(compute::Expression filter) { |
| 385 | ASSERT_OK_AND_ASSIGN(options_->filter, filter.Bind(*schema_)); |
no test coverage detected