pegasus.mapreduce.common.coordination

Class ZookeeperBooleanCounter

java.lang.Object

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

pegasus.mapreduce.common.coordination.ZookeeperBooleanCounter

All Implemented Interfaces:

Counter<java.lang.Boolean>

public class ZookeeperBooleanCounter
extends ZookeeperCounter<java.lang.Boolean>

Constructor Summary

Constructors

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

Method Summary

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

ZookeeperBooleanCounter

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

Method Detail

negativeInfinite

protected java.lang.Boolean negativeInfinite()

Specified by:

negativeInfinite in class ZookeeperCounter<java.lang.Boolean>

positiveInfinite

protected java.lang.Boolean positiveInfinite()

Specified by:

positiveInfinite in class ZookeeperCounter<java.lang.Boolean>

zero

protected java.lang.Boolean zero()

Specified by:

zero in class ZookeeperCounter<java.lang.Boolean>

sumOp

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

Specified by:

sumOp in class ZookeeperCounter<java.lang.Boolean>

valueFromString

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

Specified by:

valueFromString in class ZookeeperCounter<java.lang.Boolean>

valueToString

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

Specified by:

valueToString in class ZookeeperCounter<java.lang.Boolean>