shard (version 0.1.0)

stream_count: Stream row count

Description

Stream row count

Usage

stream_count(x)

Value

A single integer giving the total number of rows across all partitions.

Arguments

x

A shard_row_groups or shard_dataset handle.

Examples

# \donttest{
s <- schema(x = float64())
sink <- table_sink(s, mode = "row_groups")
table_write(sink, 1L, data.frame(x = rnorm(5)))
rg <- table_finalize(sink)
stream_count(rg)
# }