def bytes_produced_stats(tag):
"""Records the number of bytes produced by each element of the input dataset.
- To consume the statistics, associate a `StatsAggregator` with an iterator
- over the output dataset.
+ To consume the statistics, associate a `StatsAggregator` with the output
+ dataset.
Args:
tag: String. All statistics recorded by the returned transformation will
def latency_stats(tag):
"""Records the latency of producing each element of the input dataset.
- To consume the statistics, associate a `StatsAggregator` with an iterator
- over the output dataset.
+ To consume the statistics, associate a `StatsAggregator` with the output
+ dataset.
Args:
tag: String. All statistics recorded by the returned transformation will