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

Method execute

datafusion/core/src/physical_planner.rs:4484–4490  ·  view source on GitHub ↗
(
            &self,
            _partition: usize,
            _context: Arc<TaskContext>,
        )

Source from the content-addressed store, hash-verified

4482 }
4483
4484 fn execute(
4485 &self,
4486 _partition: usize,
4487 _context: Arc<TaskContext>,
4488 ) -> Result<SendableRecordBatchStream> {
4489 unimplemented!("NoOpExecutionPlan::execute");
4490 }
4491 }
4492
4493 // Produces an execution plan where the schema is mismatched from

Callers 15

runMethod · 0.45
test_with_projectionFunction · 0.45
test_without_projectionFunction · 0.45
test_merged_schemaFunction · 0.45
read_small_batchesFunction · 0.45
read_small_batchesFunction · 0.45
read_small_batchesFunction · 0.45
read_small_batchesFunction · 0.45
test_with_storesFunction · 0.45
avro_exec_missing_columnFunction · 0.45
avro_exec_with_partitionFunction · 0.45

Calls

no outgoing calls

Tested by 8

test_with_projectionFunction · 0.36
test_without_projectionFunction · 0.36
test_merged_schemaFunction · 0.36
test_with_storesFunction · 0.36
test_additional_storesFunction · 0.36