Package org.apache.flink.api.common.accumulators

Class DoubleMinimum

java.lang.Object

org.apache.flink.api.common.accumulators.DoubleMinimum

All Implemented Interfaces:

Serializable, Cloneable, Accumulator<Double,Double>, SimpleAccumulator<Double>

@PublicEvolving
public class DoubleMinimum
extends Object
implements SimpleAccumulator<Double>

An accumulator that finds the minimum double value.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor	Description
DoubleMinimum()
DoubleMinimum(double value)

Method Summary

Modifier and Type	Method	Description
void	add(double value)
void	add(Double value)	Consider using add(double) instead for primitive double values
DoubleMinimum	clone()	Duplicates the accumulator.
Double	getLocalValue()
double	getLocalValuePrimitive()
void	merge(Accumulator<Double,Double> other)	Used by system internally to merge the collected parts of an accumulator at the end of the job.
void	resetLocal()	Reset the local value.
String	toString()

Methods inherited from class java.lang.Object

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

Constructor Detail

DoubleMinimum

public DoubleMinimum()

DoubleMinimum

public DoubleMinimum(double value)

Method Detail

add

public void add(Double value)

Consider using add(double) instead for primitive double values

Specified by:

add in interface Accumulator<Double,Double>

Parameters:

value - The value to add to the accumulator object

getLocalValue

public Double getLocalValue()

Specified by:

getLocalValue in interface Accumulator<Double,Double>

Returns:

local The local value from the current UDF context

merge

public void merge(Accumulator<Double,Double> other)

Description copied from interface: Accumulator

Used by system internally to merge the collected parts of an accumulator at the end of the job.

Specified by:

merge in interface Accumulator<Double,Double>

Parameters:

other - Reference to accumulator to merge in.

resetLocal

public void resetLocal()

Description copied from interface: Accumulator

Reset the local value. This only affects the current UDF context.

Specified by:

resetLocal in interface Accumulator<Double,Double>

clone

public DoubleMinimum clone()

Description copied from interface: Accumulator

Duplicates the accumulator. All subclasses need to properly implement cloning and cannot throw a CloneNotSupportedException

Specified by:

clone in interface Accumulator<Double,Double>

Overrides:

clone in class Object

Returns:

The duplicated accumulator.

add

public void add(double value)

getLocalValuePrimitive

public double getLocalValuePrimitive()

toString

public String toString()

Overrides:

toString in class Object