pub async fn count_rows( batches: Inputs<RecordBatch>, counts: Outputs<usize>, total: Outputs<usize>, ) -> Result
A block that outputs row counts of input record batches.