fn execute()

in src/max_rows.rs [60:68]

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

    fn execute(
        &self,
        partition: usize,
        context: std::sync::Arc<datafusion::execution::TaskContext>,
    ) -> Result<SendableRecordBatchStream> {
        self.input
            .execute(partition, context)
            .map(|stream| max_rows_stream(stream, self.max_rows))
    }