Package org.apache.iceberg.spark.actions

Class SetAccumulator<T>

java.lang.Object
org.apache.spark.util.AccumulatorV2<T,Set<T>>
org.apache.iceberg.spark.actions.SetAccumulator<T>
All Implemented Interfaces:
Serializable, scala.Serializable
public class SetAccumulator<T> extends org.apache.spark.util.AccumulatorV2<T,Set<T>>
See Also:

  • Constructor Summary

    Constructors
    Constructor
    Description
    SetAccumulator()
     

  • Method Summary

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

    Methods inherited from class java.lang.Object

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

  • Constructor Details

    • SetAccumulator

      public SetAccumulator()

  • Method Details

    • isZero

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

    • copy

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

    • reset

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

    • add

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

    • merge

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

    • value

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