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 and Description
LocalSemaphore(int size)

Method Summary

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

LocalSemaphore

public LocalSemaphore(int size)

Method Detail

acquire

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

Specified by:

acquire in interface DistributedSemaphore

Throws:

Exception