pegasus.mapreduce.common.coordination

Class SemaphoreBarrier

java.lang.Object

pegasus.mapreduce.common.coordination.SemaphoreBarrier

All Implemented Interfaces:

org.apache.zookeeper.Watcher, Barrier

public class SemaphoreBarrier
extends java.lang.Object
implements Barrier, 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
SemaphoreBarrier(org.apache.zookeeper.ZooKeeper zk, java.lang.String name, int workerId, int parallelism, boolean isMine)

Method Summary

Modifier and Type	Method and Description
void	cleanup() Cleanups this barrier.
void	markCompleted() Marks this barrier completed.
void	process(org.apache.zookeeper.WatchedEvent event)
void	setup() Initializes the barrier.
java.lang.String	toString()
void	waitBarrier() Waits until this barrier is marked as completed.

Methods inherited from class java.lang.Object

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

Constructor Detail

SemaphoreBarrier

public SemaphoreBarrier(org.apache.zookeeper.ZooKeeper zk,
                        java.lang.String name,
                        int workerId,
                        int parallelism,
                        boolean isMine)

Method Detail

setup

public void setup()

Description copied from interface: Barrier

Initializes the barrier.

Specified by:

setup in interface Barrier

markCompleted

public void markCompleted()

Description copied from interface: Barrier

Marks this barrier completed.

Specified by:

markCompleted in interface Barrier

waitBarrier

public void waitBarrier()

Description copied from interface: Barrier

Waits until this barrier is marked as completed.

Specified by:

waitBarrier in interface Barrier

cleanup

public void cleanup()

Description copied from interface: Barrier

Cleanups this barrier.

Specified by:

cleanup in interface Barrier

process

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

Specified by:

process in interface org.apache.zookeeper.Watcher

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object