pegasus.mapreduce.common.coordination

Class ZookeeperLongCounter

java.lang.Object

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

pegasus.mapreduce.common.coordination.ZookeeperLongCounter

All Implemented Interfaces:

Counter<java.lang.Long>

public class ZookeeperLongCounter
extends ZookeeperCounter<java.lang.Long>

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
protected java.lang.Long	negativeInfinite()
protected java.lang.Long	positiveInfinite()
protected java.util.function.BinaryOperator<java.lang.Long>	sumOp()
protected java.lang.Long	valueFromString(java.lang.String string)
protected java.lang.String	valueToString(java.lang.Long value)
protected java.lang.Long	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

ZookeeperLongCounter

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

Method Detail

negativeInfinite

protected java.lang.Long negativeInfinite()

Specified by:

negativeInfinite in class ZookeeperCounter<java.lang.Long>

positiveInfinite

protected java.lang.Long positiveInfinite()

Specified by:

positiveInfinite in class ZookeeperCounter<java.lang.Long>

zero

protected java.lang.Long zero()

Specified by:

zero in class ZookeeperCounter<java.lang.Long>

sumOp

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

Specified by:

sumOp in class ZookeeperCounter<java.lang.Long>

valueFromString

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

Specified by:

valueFromString in class ZookeeperCounter<java.lang.Long>

valueToString

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

Specified by:

valueToString in class ZookeeperCounter<java.lang.Long>