Package org.apache.beam.runners.spark.metrics

Class MetricsContainerStepMapAccumulator

java.lang.Object
org.apache.spark.util.AccumulatorV2<org.apache.beam.runners.core.metrics.MetricsContainerStepMap,org.apache.beam.runners.core.metrics.MetricsContainerStepMap>
org.apache.beam.runners.spark.metrics.MetricsContainerStepMapAccumulator
All Implemented Interfaces:
Serializable, scala.Serializable
public class MetricsContainerStepMapAccumulator extends org.apache.spark.util.AccumulatorV2<org.apache.beam.runners.core.metrics.MetricsContainerStepMap,org.apache.beam.runners.core.metrics.MetricsContainerStepMap>
AccumulatorV2 implementation for MetricsContainerStepMap.
See Also:

  • Constructor Summary

    Constructors
    Constructor
    Description
    MetricsContainerStepMapAccumulator(org.apache.beam.runners.core.metrics.MetricsContainerStepMap value)
     

  • Method Summary

    Modifier and Type
    Method
    Description
    void
    add(org.apache.beam.runners.core.metrics.MetricsContainerStepMap other)
     
    MetricsContainerStepMapAccumulator
    copy()
     
    boolean
    isZero()
     
    void
    merge(org.apache.spark.util.AccumulatorV2<org.apache.beam.runners.core.metrics.MetricsContainerStepMap,org.apache.beam.runners.core.metrics.MetricsContainerStepMap> other)
     
    void
    reset()
     
    org.apache.beam.runners.core.metrics.MetricsContainerStepMap
    value()
     

    Methods inherited from class org.apache.spark.util.AccumulatorV2

    copyAndReset, countFailedValues, id, isAtDriverSide, isRegistered, metadata, metadata_$eq, name, register, register$default$2, register$default$3, toInfo, toString, withBufferSerialized, writeReplace

    Methods inherited from class java.lang.Object

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

  • Constructor Details

    • MetricsContainerStepMapAccumulator

      public MetricsContainerStepMapAccumulator(org.apache.beam.runners.core.metrics.MetricsContainerStepMap value)

  • Method Details

    • isZero

      public boolean isZero()
      Specified by:
      isZero in class org.apache.spark.util.AccumulatorV2<org.apache.beam.runners.core.metrics.MetricsContainerStepMap,org.apache.beam.runners.core.metrics.MetricsContainerStepMap>

    • copy

      public MetricsContainerStepMapAccumulator copy()
      Specified by:
      copy in class org.apache.spark.util.AccumulatorV2<org.apache.beam.runners.core.metrics.MetricsContainerStepMap,org.apache.beam.runners.core.metrics.MetricsContainerStepMap>

    • reset

      public void reset()
      Specified by:
      reset in class org.apache.spark.util.AccumulatorV2<org.apache.beam.runners.core.metrics.MetricsContainerStepMap,org.apache.beam.runners.core.metrics.MetricsContainerStepMap>

    • add

      public void add(org.apache.beam.runners.core.metrics.MetricsContainerStepMap other)
      Specified by:
      add in class org.apache.spark.util.AccumulatorV2<org.apache.beam.runners.core.metrics.MetricsContainerStepMap,org.apache.beam.runners.core.metrics.MetricsContainerStepMap>

    • merge

      public void merge(org.apache.spark.util.AccumulatorV2<org.apache.beam.runners.core.metrics.MetricsContainerStepMap,org.apache.beam.runners.core.metrics.MetricsContainerStepMap> other)
      Specified by:
      merge in class org.apache.spark.util.AccumulatorV2<org.apache.beam.runners.core.metrics.MetricsContainerStepMap,org.apache.beam.runners.core.metrics.MetricsContainerStepMap>

    • value

      public org.apache.beam.runners.core.metrics.MetricsContainerStepMap value()
      Specified by:
      value in class org.apache.spark.util.AccumulatorV2<org.apache.beam.runners.core.metrics.MetricsContainerStepMap,org.apache.beam.runners.core.metrics.MetricsContainerStepMap>