Function count_rows 

pub async fn count_rows(
    batches: Inputs<RecordBatch>,
    counts: Outputs<usize>,
    total: Outputs<usize, 1>,
) -> Result<(), Error>

A block that outputs row counts of input record batches.