com.graphdbapi.parkit.accumulator

Class CommonAccumulator<IN,OUT>

java.lang.Object

com.graphdbapi.parkit.accumulator.CommonAccumulator<IN,OUT>

All Implemented Interfaces:

Accumulator<IN,OUT>

Direct Known Subclasses:

MaxByteAccumulator, MaxDoubleAccumulator, MaxFloatAccumulator, MaxIntAccumulator, MaxLongAccumulator, MaxShortAccumulator, MinByteAccumulator, MinDoubleAccumulator, MinFloatAccumulator, MinIntAccumulator, MinLongAccumulator, MinShortAccumulator, SumByteAccumulator, SumDoubleAccumulator, SumFloatAccumulator, SumIntAccumulator, SumLongAccumulator, SumShortAccumulator

public abstract class CommonAccumulator<IN,OUT>
extends java.lang.Object
implements Accumulator<IN,OUT>

添加公共累积器

Field Summary

Fields

Modifier and Type	Field and Description
protected OUT	defaultValue
protected java.util.concurrent.atomic.AtomicReference<OUT>	values

Constructor Summary

Constructors

Constructor and Description
CommonAccumulator(OUT value)

Method Summary

Modifier and Type	Method and Description
OUT	getAvgSum() 获取avg的总和值 备注: 集合类型调用返回null
java.lang.Long	getNum() 用于avg的返回数量
boolean	isZero() 判断是否是初始值
void	reset() 重置累计器的值
OUT	value() 返回累计器的值

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.graphdbapi.parkit.accumulator.Accumulator

add, copy, merge

Field Detail

values

protected java.util.concurrent.atomic.AtomicReference<OUT> values

defaultValue

protected OUT defaultValue

Constructor Detail

CommonAccumulator

public CommonAccumulator(OUT value)

Method Detail

reset

public void reset()

Description copied from interface: Accumulator

重置累计器的值

Specified by:

reset in interface Accumulator<IN,OUT>

value

public OUT value()

Description copied from interface: Accumulator

返回累计器的值

Specified by:

value in interface Accumulator<IN,OUT>

Returns:

累计器的值

isZero

public boolean isZero()

Description copied from interface: Accumulator

判断是否是初始值

Specified by:

isZero in interface Accumulator<IN,OUT>

Returns:

是否是初始值

getNum

public java.lang.Long getNum()

Description copied from interface: Accumulator

用于avg的返回数量

Specified by:

getNum in interface Accumulator<IN,OUT>

Returns:

返回累计数量

getAvgSum

public OUT getAvgSum()

Description copied from interface: Accumulator

获取avg的总和值 备注: 集合类型调用返回null

Specified by:

getAvgSum in interface Accumulator<IN,OUT>

Returns:

返回avg的总和值