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

Method execute

datafusion/physical-plan/src/execution_plan.rs:1603–1609  ·  view source on GitHub ↗
(
            &self,
            _partition: usize,
            _context: Arc<TaskContext>,
        )

Source from the content-addressed store, hash-verified

1601 }
1602
1603 fn execute(
1604 &self,
1605 _partition: usize,
1606 _context: Arc<TaskContext>,
1607 ) -> Result<SendableRecordBatchStream> {
1608 unimplemented!()
1609 }
1610
1611 fn partition_statistics(
1612 &self,

Callers 3

execute_streamFunction · 0.45
execute_input_streamFunction · 0.45

Calls

no outgoing calls

Tested by

no test coverage detected