The user-facing concept is called metrics. See https://github.com/apache/beam/blob/master/sdks/java/core/src/main/java/org/apache/beam/sdk/metrics/Metrics.java
On Wed, Mar 22, 2017 at 5:55 PM, Newport, Billy <[email protected]> wrote: > 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 > > >
