Package org.apache.drill.exec.coord.zk

Class ZkDistributedSemaphore

java.lang.Object

org.apache.drill.exec.coord.zk.ZkDistributedSemaphore

All Implemented Interfaces:

DistributedSemaphore

public class ZkDistributedSemaphore
extends Object
implements DistributedSemaphore

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.drill.exec.coord.DistributedSemaphore

DistributedSemaphore.DistributedLease

Constructor Summary

Constructors

Constructor	Description
ZkDistributedSemaphore(org.apache.curator.framework.CuratorFramework client, String path, int numberOfLeases)

Method Summary

Modifier and Type	Method	Description
DistributedSemaphore.DistributedLease	acquire(long time, TimeUnit unit)

Methods inherited from class java.lang.Object

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

Constructor Details

ZkDistributedSemaphore

public ZkDistributedSemaphore(org.apache.curator.framework.CuratorFramework client,
 String path,
 int numberOfLeases)

Method Details

acquire

public DistributedSemaphore.DistributedLease acquire(long time,
 TimeUnit unit)
                                              throws Exception

Specified by:

acquire in interface DistributedSemaphore

Throws:

Exception