pegasus.mapreduce.common.coordination

Class ZookeeperDoubleCounter

java.lang.Object

pegasus.mapreduce.common.coordination.ZookeeperCounter<java.lang.Double>

pegasus.mapreduce.common.coordination.ZookeeperDoubleCounter

All Implemented Interfaces:

Counter<java.lang.Double>

public class ZookeeperDoubleCounter
extends ZookeeperCounter<java.lang.Double>

Constructor Summary

Constructors

Constructor and Description
ZookeeperDoubleCounter(org.apache.zookeeper.ZooKeeper zk, java.lang.String name, int workerId)

Method Summary

Modifier and Type	Method and Description
protected java.lang.Double	negativeInfinite()
protected java.lang.Double	positiveInfinite()
protected java.util.function.BinaryOperator<java.lang.Double>	sumOp()
protected java.lang.Double	valueFromString(java.lang.String string)
protected java.lang.String	valueToString(java.lang.Double value)
protected java.lang.Double	zero()

Methods inherited from class pegasus.mapreduce.common.coordination.ZookeeperCounter

getMaximum, getMinimum, getSum, update

Methods inherited from class java.lang.Object

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

Constructor Detail

ZookeeperDoubleCounter

public ZookeeperDoubleCounter(org.apache.zookeeper.ZooKeeper zk,
                              java.lang.String name,
                              int workerId)

Method Detail

negativeInfinite

protected java.lang.Double negativeInfinite()

Specified by:

negativeInfinite in class ZookeeperCounter<java.lang.Double>

positiveInfinite

protected java.lang.Double positiveInfinite()

Specified by:

positiveInfinite in class ZookeeperCounter<java.lang.Double>

zero

protected java.lang.Double zero()

Specified by:

zero in class ZookeeperCounter<java.lang.Double>

sumOp

protected java.util.function.BinaryOperator<java.lang.Double> sumOp()

Specified by:

sumOp in class ZookeeperCounter<java.lang.Double>

valueFromString

protected java.lang.Double valueFromString(java.lang.String string)

Specified by:

valueFromString in class ZookeeperCounter<java.lang.Double>

valueToString

protected java.lang.String valueToString(java.lang.Double value)

Specified by:

valueToString in class ZookeeperCounter<java.lang.Double>