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

Function get_exec

datafusion/core/src/datasource/file_format/avro.rs:380–399  ·  view source on GitHub ↗
(
        state: &dyn Session,
        file_name: &str,
        projection: Option<Vec<usize>>,
        limit: Option<usize>,
    )

Source from the content-addressed store, hash-verified

378 }
379
380 async fn get_exec(
381 state: &dyn Session,
382 file_name: &str,
383 projection: Option<Vec<usize>>,
384 limit: Option<usize>,
385 ) -> Result<Arc<dyn ExecutionPlan>> {
386 let testdata = test_util::arrow_test_data();
387 let store_root = format!("{testdata}/avro");
388 let format = AvroFormat {};
389 scan_format(
390 state,
391 &format,
392 None,
393 &store_root,
394 file_name,
395 projection,
396 limit,
397 )
398 .await
399 }
400}

Calls 2

arrow_test_dataFunction · 0.85
scan_formatFunction · 0.85

Tested by

no test coverage detected

Used in the wild real call sites across dependent graphs

searching dependent graphs…