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

Function get_exec

datafusion/core/src/datasource/file_format/json.rs:190–198  ·  view source on GitHub ↗
(
        state: &dyn Session,
        projection: Option<Vec<usize>>,
        limit: Option<usize>,
    )

Source from the content-addressed store, hash-verified

188 }
189
190 async fn get_exec(
191 state: &dyn Session,
192 projection: Option<Vec<usize>>,
193 limit: Option<usize>,
194 ) -> Result<Arc<dyn ExecutionPlan>> {
195 let filename = "tests/data/2.json";
196 let format = JsonFormat::default();
197 scan_format(state, &format, None, ".", filename, projection, limit).await
198 }
199
200 #[tokio::test]
201 async fn infer_schema_with_limit() {

Callers 4

read_small_batchesFunction · 0.70
read_limitFunction · 0.70
infer_schemaFunction · 0.70
read_int_columnFunction · 0.70

Calls 1

scan_formatFunction · 0.85

Tested by

no test coverage detected

Used in the wild real call sites across dependent graphs

searching dependent graphs…