pegasus.mapreduce.common.coordination

Class ZookeeperIntegerCounter

java.lang.Object

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

pegasus.mapreduce.common.coordination.ZookeeperIntegerCounter

All Implemented Interfaces:

Counter<java.lang.Integer>

public class ZookeeperIntegerCounter
extends ZookeeperCounter<java.lang.Integer>

Constructor Summary

Constructors

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

Method Summary

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

ZookeeperIntegerCounter

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

Method Detail

negativeInfinite

protected java.lang.Integer negativeInfinite()

Specified by:

negativeInfinite in class ZookeeperCounter<java.lang.Integer>

positiveInfinite

protected java.lang.Integer positiveInfinite()

Specified by:

positiveInfinite in class ZookeeperCounter<java.lang.Integer>

zero

protected java.lang.Integer zero()

Specified by:

zero in class ZookeeperCounter<java.lang.Integer>

sumOp

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

Specified by:

sumOp in class ZookeeperCounter<java.lang.Integer>

valueFromString

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

Specified by:

valueFromString in class ZookeeperCounter<java.lang.Integer>

valueToString

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

Specified by:

valueToString in class ZookeeperCounter<java.lang.Integer>