pegasus.mapreduce.common.coordination

Class ZookeeperCounter<T extends java.lang.Comparable<T>>

java.lang.Object

pegasus.mapreduce.common.coordination.ZookeeperCounter<T>

All Implemented Interfaces:

Counter<T>

Direct Known Subclasses:

ZookeeperBooleanCounter, ZookeeperDoubleCounter, ZookeeperIntegerCounter, ZookeeperLongCounter

public abstract class ZookeeperCounter<T extends java.lang.Comparable<T>>
extends java.lang.Object
implements Counter<T>

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
T	getMaximum()
T	getMinimum()
T	getSum()
protected abstract T	negativeInfinite()
protected abstract T	positiveInfinite()
protected abstract java.util.function.BinaryOperator<T>	sumOp()
void	update(T value)
protected abstract T	valueFromString(java.lang.String string)
protected abstract java.lang.String	valueToString(T value)
protected abstract T	zero()

Methods inherited from class java.lang.Object

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

Constructor Detail

ZookeeperCounter

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

Method Detail

update

public void update(T value)

Specified by:

update in interface Counter<T extends java.lang.Comparable<T>>

getMinimum

public T getMinimum()

Specified by:

getMinimum in interface Counter<T extends java.lang.Comparable<T>>

getMaximum

public T getMaximum()

Specified by:

getMaximum in interface Counter<T extends java.lang.Comparable<T>>

getSum

public T getSum()

Specified by:

getSum in interface Counter<T extends java.lang.Comparable<T>>

negativeInfinite

protected abstract T negativeInfinite()

positiveInfinite

protected abstract T positiveInfinite()

zero

protected abstract T zero()

sumOp

protected abstract java.util.function.BinaryOperator<T> sumOp()

valueFromString

protected abstract T valueFromString(java.lang.String string)

valueToString

protected abstract java.lang.String valueToString(T value)