Method execute

datafusion/core/tests/fuzz_cases/once_exec.rs:97–107

Returns a stream which yields data

(
        &self,
        partition: usize,
        _context: Arc<TaskContext>,
    )

    /// Returns a stream which yields data
    fn execute(
        &self,
        partition: usize,
        _context: Arc<TaskContext>,
    ) -> datafusion_common::Result<SendableRecordBatchStream> {
        assert_eq!(partition, 0);

        let stream = self.stream.lock().unwrap().take();

        stream.ok_or_else(|| internal_datafusion_err!("Stream already consumed"))
    }
}