pegasus.mapreduce.common.coordination

Class CoordinationService

java.lang.Object

pegasus.mapreduce.common.coordination.CoordinationService

All Implemented Interfaces:

org.apache.zookeeper.Watcher

public class CoordinationService
extends java.lang.Object
implements org.apache.zookeeper.Watcher

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.zookeeper.Watcher

org.apache.zookeeper.Watcher.Event

Constructor Summary

Constructors

Constructor and Description
CoordinationService()

Method Summary

Modifier and Type	Method and Description
void	cleanup(org.apache.hadoop.mapreduce.TaskAttemptContext context)
Counter<java.lang.Long>	getHadoopCounter(java.lang.String name)
Barrier	getMutexBarrier(java.lang.String name, int mutexId, boolean isMine)
Barrier	getSemaphoreBarrier(java.lang.String name)
java.lang.String	getServiceAddress()
int	getWorkerId()
<T extends java.lang.Comparable<T>> Counter<T>	getZkCounter(java.lang.String name, java.lang.Class<T> clazz)
void	process(org.apache.zookeeper.WatchedEvent event)
void	setup(org.apache.hadoop.mapreduce.TaskAttemptContext context)

Methods inherited from class java.lang.Object

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

Constructor Detail

CoordinationService

public CoordinationService()

Method Detail

setup

public final void setup(org.apache.hadoop.mapreduce.TaskAttemptContext context)
                 throws java.io.IOException,
                        java.lang.InterruptedException,
                        org.apache.zookeeper.KeeperException

Throws:

java.io.IOException

java.lang.InterruptedException

org.apache.zookeeper.KeeperException

cleanup

public final void cleanup(org.apache.hadoop.mapreduce.TaskAttemptContext context)
                   throws java.lang.InterruptedException

Throws:

java.lang.InterruptedException

getWorkerId

public final int getWorkerId()

getServiceAddress

public final java.lang.String getServiceAddress()

process

public void process(org.apache.zookeeper.WatchedEvent event)

Specified by:

process in interface org.apache.zookeeper.Watcher

getSemaphoreBarrier

public Barrier getSemaphoreBarrier(java.lang.String name)

getMutexBarrier

public Barrier getMutexBarrier(java.lang.String name,
                               int mutexId,
                               boolean isMine)

getZkCounter

public <T extends java.lang.Comparable<T>> Counter<T> getZkCounter(java.lang.String name,
                                                                   java.lang.Class<T> clazz)

getHadoopCounter

public Counter<java.lang.Long> getHadoopCounter(java.lang.String name)