fn execute()

in src/stage.rs [163:169]

• 7 lines of code
• 1 McCabe index (conditional complexity)

    fn execute(
        &self,
        _partition: usize,
        _context: std::sync::Arc<datafusion::execution::TaskContext>,
    ) -> Result<SendableRecordBatchStream> {
        unimplemented!("Ray Stage Exec")
    }