Package org.apache.beam.runners.flink.metrics

Class MetricsAccumulator

java.lang.Object
org.apache.beam.runners.flink.metrics.MetricsAccumulator
All Implemented Interfaces:
Serializable, Cloneable, org.apache.flink.api.common.accumulators.Accumulator<org.apache.beam.runners.core.metrics.MetricsContainerStepMap,org.apache.beam.runners.core.metrics.MetricsContainerStepMap>, org.apache.flink.api.common.accumulators.SimpleAccumulator<org.apache.beam.runners.core.metrics.MetricsContainerStepMap>
public class MetricsAccumulator extends Object implements org.apache.flink.api.common.accumulators.SimpleAccumulator<org.apache.beam.runners.core.metrics.MetricsContainerStepMap>
Accumulator of MetricsContainerStepMap. This accumulator will only be reported to Flink when the job ends. This avoids the runtime overhead for accumulators which are continously sent to the job manager.
See Also:

  • Constructor Summary

    Constructors
    Constructor
    Description
    MetricsAccumulator()
     

  • Method Summary

    Modifier and Type
    Method
    Description
    void
    add(org.apache.beam.runners.core.metrics.MetricsContainerStepMap value)
     
    org.apache.flink.api.common.accumulators.Accumulator<org.apache.beam.runners.core.metrics.MetricsContainerStepMap,org.apache.beam.runners.core.metrics.MetricsContainerStepMap>
    clone()
     
    org.apache.beam.runners.core.metrics.MetricsContainerStepMap
    getLocalValue()
     
    void
    merge(org.apache.flink.api.common.accumulators.Accumulator<org.apache.beam.runners.core.metrics.MetricsContainerStepMap,org.apache.beam.runners.core.metrics.MetricsContainerStepMap> other)
     
    void
    resetLocal()
     

    Methods inherited from class java.lang.Object

    equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

  • Constructor Details

    • MetricsAccumulator

      public MetricsAccumulator()

  • Method Details

    • add

      public void add(org.apache.beam.runners.core.metrics.MetricsContainerStepMap value)
      Specified by:
      add in interface org.apache.flink.api.common.accumulators.Accumulator<org.apache.beam.runners.core.metrics.MetricsContainerStepMap,org.apache.beam.runners.core.metrics.MetricsContainerStepMap>

    • getLocalValue

      public org.apache.beam.runners.core.metrics.MetricsContainerStepMap getLocalValue()
      Specified by:
      getLocalValue in interface org.apache.flink.api.common.accumulators.Accumulator<org.apache.beam.runners.core.metrics.MetricsContainerStepMap,org.apache.beam.runners.core.metrics.MetricsContainerStepMap>

    • resetLocal

      public void resetLocal()
      Specified by:
      resetLocal in interface org.apache.flink.api.common.accumulators.Accumulator<org.apache.beam.runners.core.metrics.MetricsContainerStepMap,org.apache.beam.runners.core.metrics.MetricsContainerStepMap>

    • merge

      public void merge(org.apache.flink.api.common.accumulators.Accumulator<org.apache.beam.runners.core.metrics.MetricsContainerStepMap,org.apache.beam.runners.core.metrics.MetricsContainerStepMap> other)
      Specified by:
      merge in interface org.apache.flink.api.common.accumulators.Accumulator<org.apache.beam.runners.core.metrics.MetricsContainerStepMap,org.apache.beam.runners.core.metrics.MetricsContainerStepMap>

    • clone

      public org.apache.flink.api.common.accumulators.Accumulator<org.apache.beam.runners.core.metrics.MetricsContainerStepMap,org.apache.beam.runners.core.metrics.MetricsContainerStepMap> clone()
      Specified by:
      clone in interface org.apache.flink.api.common.accumulators.Accumulator<org.apache.beam.runners.core.metrics.MetricsContainerStepMap,org.apache.beam.runners.core.metrics.MetricsContainerStepMap>
      Overrides:
      clone in class Object