I'm using Flink accumulators to track different metrics as I process all elements in a Dataset. I retrieve these counters at the end of the job and update a database with the values.
Is there a similar concept in Beam. I see CounterCell and Counter but they seem to be just for runners. Thanks
