Package com.linkedin.venice.spark.datawriter.task

Class MaxAccumulator<T extends Comparable<T>>

java.lang.Object
org.apache.spark.util.AccumulatorV2<T,T>
com.linkedin.venice.spark.datawriter.task.MaxAccumulator<T>
All Implemented Interfaces:
Serializable, scala.Serializable
public class MaxAccumulator<T extends Comparable<T>> extends org.apache.spark.util.AccumulatorV2<T,T>
See Also:

  • Method Summary

    Modifier and Type
    Method
    Description
    void
    add(T v)
     
    org.apache.spark.util.AccumulatorV2<T,T>
    copy()
     
    boolean
    isZero()
     
    void
    merge(org.apache.spark.util.AccumulatorV2<T,T> other)
     
    void
    reset()
     
    T
    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

  • Method Details

    • isZero

      public boolean isZero()
      Specified by:
      isZero in class org.apache.spark.util.AccumulatorV2<T extends Comparable<T>,T extends Comparable<T>>

    • copy

      public org.apache.spark.util.AccumulatorV2<T,T> copy()
      Specified by:
      copy in class org.apache.spark.util.AccumulatorV2<T extends Comparable<T>,T extends Comparable<T>>

    • reset

      public void reset()
      Specified by:
      reset in class org.apache.spark.util.AccumulatorV2<T extends Comparable<T>,T extends Comparable<T>>

    • add

      public void add(T v)
      Specified by:
      add in class org.apache.spark.util.AccumulatorV2<T extends Comparable<T>,T extends Comparable<T>>

    • merge

      public void merge(org.apache.spark.util.AccumulatorV2<T,T> other)
      Specified by:
      merge in class org.apache.spark.util.AccumulatorV2<T extends Comparable<T>,T extends Comparable<T>>

    • value

      public T value()
      Specified by:
      value in class org.apache.spark.util.AccumulatorV2<T extends Comparable<T>,T extends Comparable<T>>