MCPcopy Create free account
hub / github.com/apache/datafusion / with_records

Method with_records

datafusion/datasource/src/file_stream/mod.rs:287–290  ·  view source on GitHub ↗

Specify the record batches that should be returned from each file that is successfully scanned

(mut self, records: Vec<RecordBatch>)

Source from the content-addressed store, hash-verified

285 /// Specify the record batches that should be returned from each
286 /// file that is successfully scanned
287 pub fn with_records(mut self, records: Vec<RecordBatch>) -> Self {
288 self.opener.records = records;
289 self
290 }
291
292 /// Collect the results of the `FileStream`
293 pub async fn result(self) -> Result<Vec<RecordBatch>> {

Callers 6

create_and_collectFunction · 0.80
on_error_openingFunction · 0.80
on_error_scanning_failFunction · 0.80
on_error_opening_failFunction · 0.80
on_error_scanningFunction · 0.80
on_error_mixedFunction · 0.80

Calls

no outgoing calls

Tested by

no test coverage detected