Method Scan

cpp/src/arrow/dataset/test_util_internal.h:1263–1275

Scan the fragment through the scanner.

  // Scan the fragment through the scanner.
  Result<std::unique_ptr<RecordBatchReader>> Scan(std::shared_ptr<Fragment> fragment,
                                                  bool add_filter_fields = true) {
    opts_->dataset =
        std::make_shared<FragmentDataset>(dataset_schema_, FragmentVector{fragment});
    if (add_filter_fields) {
      ARROW_RETURN_NOT_OK(ScanV2Options::AddFieldsNeededForFilter(opts_.get()));
    }
    opts_->format_options = GetFormatOptions();
    ARROW_ASSIGN_OR_RAISE(std::unique_ptr<RecordBatchReader> reader,
                          acero::DeclarationToReader(acero::Declaration("scan2", *opts_),
                                                     GetParam().use_threads));
    return reader;
  }

  // Return a batch iterator which scans the fragment through the scanner.
  //