Package org.apache.drill.exec.coord.local

Class LocalClusterCoordinator.LocalSemaphore

java.lang.Object

org.apache.drill.exec.coord.local.LocalClusterCoordinator.LocalSemaphore

All Implemented Interfaces:

DistributedSemaphore

Enclosing class:

LocalClusterCoordinator

public class LocalClusterCoordinator.LocalSemaphore
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
LocalSemaphore(int size)

Method Summary

Modifier and Type	Method	Description
DistributedSemaphore.DistributedLease	acquire(long timeout, TimeUnit timeUnit)

Methods inherited from class java.lang.Object

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

Constructor Details

LocalSemaphore

public LocalSemaphore(int size)

Method Details

acquire

public DistributedSemaphore.DistributedLease acquire(long timeout,
 TimeUnit timeUnit)
                                              throws Exception

Specified by:

acquire in interface DistributedSemaphore

Throws:

Exception