Method build

datafusion/core/tests/physical_optimizer/pushdown_utils.rs:265–276

(self)

    }

    pub fn build(self) -> Arc<dyn ExecutionPlan> {
        let source = Arc::new(TestSource::new(
            Arc::clone(&self.schema),
            self.support,
            self.batches,
        ));
        let base_config =
            FileScanConfigBuilder::new(ObjectStoreUrl::parse("test://").unwrap(), source)
                .with_file(PartitionedFile::new("test.parquet", 123))
                .build();
        DataSourceExec::from_data_source(base_config)
    }
}

/// Index into the data that has been returned so far