org.apache.spark.util

Class LegacyAccumulatorWrapper<R,T>

Object

org.apache.spark.util.AccumulatorV2<T,R>

org.apache.spark.util.LegacyAccumulatorWrapper<R,T>

All Implemented Interfaces:

java.io.Serializable

public class LegacyAccumulatorWrapper<R,T>
extends AccumulatorV2<T,R>

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
LegacyAccumulatorWrapper(R initialValue, AccumulableParam<R,T> param)

Method Summary

Methods

Modifier and Type	Method and Description
void	add(T v) Takes the inputs and accumulates.
LegacyAccumulatorWrapper<R,T>	copy() Creates a new copy of this accumulator.
boolean	isZero() Returns if this accumulator is zero value or not.
void	merge(AccumulatorV2<T,R> other) Merges another same-type accumulator into this one and update its state, i.e.
void	reset() Resets this accumulator, which is zero value.
R	value() Defines the current value of this accumulator

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

copyAndReset, id, isRegistered, name, toString

Methods inherited from class Object

equals, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

LegacyAccumulatorWrapper

public LegacyAccumulatorWrapper(R initialValue,
                        AccumulableParam<R,T> param)

Method Detail

isZero

public boolean isZero()

Description copied from class: AccumulatorV2

Returns if this accumulator is zero value or not. e.g. for a counter accumulator, 0 is zero value; for a list accumulator, Nil is zero value.

Specified by:

isZero in class AccumulatorV2<T,R>

Returns:

(undocumented)

copy

public LegacyAccumulatorWrapper<R,T> copy()

Description copied from class: AccumulatorV2

Creates a new copy of this accumulator.

Specified by:

copy in class AccumulatorV2<T,R>

Returns:

(undocumented)

reset

public void reset()

Description copied from class: AccumulatorV2

Resets this accumulator, which is zero value. i.e. call isZero must return true.

Specified by:

reset in class AccumulatorV2<T,R>

add

public void add(T v)

Description copied from class: AccumulatorV2

Takes the inputs and accumulates. e.g. it can be a simple += for counter accumulator.

Specified by:

add in class AccumulatorV2<T,R>

Parameters:

v - (undocumented)

merge

public void merge(AccumulatorV2<T,R> other)

Description copied from class: AccumulatorV2

Merges another same-type accumulator into this one and update its state, i.e. this should be merge-in-place.

Specified by:

merge in class AccumulatorV2<T,R>

Parameters:

other - (undocumented)

value

public R value()

Description copied from class: AccumulatorV2

Defines the current value of this accumulator

Specified by:

value in class AccumulatorV2<T,R>

Returns:

(undocumented)