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 and Description
ZkDistributedSemaphore(org.apache.curator.framework.CuratorFramework client, String path, int numberOfLeases)

Method Summary

Modifier and Type	Method and 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 Detail

ZkDistributedSemaphore

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

Method Detail

acquire

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

Specified by:

acquire in interface DistributedSemaphore

Throws:

Exception