[ https://issues.apache.org/jira/browse/BEAM-1616?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15894733#comment-15894733 ]
Ben Chambers commented on BEAM-1616: ------------------------------------ One thing we'll need to document clearly is what the behavior is across retries and such. Specifically, is this: 1. Last value reported across the pipeline 2. Last value reported for each worker, and then summed (in which case, what happens when old workers are shut down) 3. Last value reported for each work unit, and then summed (discarding failed work-units?) > Gauge Metric type > ----------------- > > Key: BEAM-1616 > URL: https://issues.apache.org/jira/browse/BEAM-1616 > Project: Beam > Issue Type: Bug > Components: beam-model, sdk-java-core, sdk-py > Reporter: Aviem Zur > Assignee: Ben Chambers > > Add support for Gauge metric type to the SDK. > This will serve to get the last value reported. > Interface should be along the lines of: > {code} > void set(long value); > {code} > Compare to > http://metrics.dropwizard.io/3.1.0/apidocs/com/codahale/metrics/Gauge.html -- This message was sent by Atlassian JIRA (v6.3.15#6346)