count_rows

flows_arrow

Function count_rows 

Source 
pub async fn count_rows(
    batches: Inputs<RecordBatch>,
    counts: Outputs<usize>,
    total: Output<usize>,
) -> Result
Expand description

A block that outputs row counts of input record batches.