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

Class LocalClusterCoordinator

java.lang.Object

org.apache.drill.exec.coord.ClusterCoordinator

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

All Implemented Interfaces:

AutoCloseable

public class LocalClusterCoordinator
extends ClusterCoordinator

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
class	LocalClusterCoordinator.LocalSemaphore

Nested classes/interfaces inherited from class org.apache.drill.exec.coord.ClusterCoordinator

ClusterCoordinator.RegistrationHandle

Field Summary

Fields inherited from class org.apache.drill.exec.coord.ClusterCoordinator

listeners

Constructor Summary

Constructors

Constructor	Description
LocalClusterCoordinator()

Method Summary

Modifier and Type	Method	Description
void	close()
Collection<CoordinationProtos.DrillbitEndpoint>	getAvailableEndpoints()	Get a collection of available Drillbit endpoints, Thread-safe.
Collection<CoordinationProtos.DrillbitEndpoint>	getOnlineEndPoints()	Get a collection of ONLINE Drillbit endpoints by excluding the drillbits that are in QUIESCENT state (drillbits shutting down).
<V> TransientStore<V>	getOrCreateTransientStore(TransientStoreConfig<V> config)	Returns a store instance with the given configuration.
DistributedSemaphore	getSemaphore(String name, int maximumLeases)
ClusterCoordinator.RegistrationHandle	register(CoordinationProtos.DrillbitEndpoint data)
void	start(long millis)	Start the cluster coordinator.
void	unregister(ClusterCoordinator.RegistrationHandle handle)
ClusterCoordinator.RegistrationHandle	update(ClusterCoordinator.RegistrationHandle handle, CoordinationProtos.DrillbitEndpoint.State state)	Update drillbit endpoint state.

Methods inherited from class org.apache.drill.exec.coord.ClusterCoordinator

addDrillbitStatusListener, drillbitRegistered, drillbitUnregistered, isDrillbitInState, removeDrillbitStatusListener

Methods inherited from class java.lang.Object

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

Constructor Details

LocalClusterCoordinator

public LocalClusterCoordinator()

Method Details

close

public void close()
           throws Exception

Throws:

Exception

start

public void start(long millis)
           throws Exception

Description copied from class: ClusterCoordinator

Start the cluster coordinator. Millis to wait is

Specified by:

start in class ClusterCoordinator

Parameters:

millis - The maximum time to wait before throwing an exception if the cluster coordination service has not successfully started. Use 0 to wait indefinitely.

Throws:

Exception - in case when unable to start coordinator

register

public ClusterCoordinator.RegistrationHandle register(CoordinationProtos.DrillbitEndpoint data)

Specified by:

register in class ClusterCoordinator

unregister

public void unregister(ClusterCoordinator.RegistrationHandle handle)

Specified by:

unregister in class ClusterCoordinator

update

public ClusterCoordinator.RegistrationHandle update(ClusterCoordinator.RegistrationHandle handle,
 CoordinationProtos.DrillbitEndpoint.State state)

Update drillbit endpoint state. Drillbit advertises its state. State information is used during planning and initial client connection phases.

Specified by:

update in class ClusterCoordinator

getAvailableEndpoints

public Collection<CoordinationProtos.DrillbitEndpoint> getAvailableEndpoints()

Description copied from class: ClusterCoordinator

Get a collection of available Drillbit endpoints, Thread-safe. Could be slightly out of date depending on refresh policy.

Specified by:

getAvailableEndpoints in class ClusterCoordinator

Returns:

A collection of available endpoints.

getOnlineEndPoints

public Collection<CoordinationProtos.DrillbitEndpoint> getOnlineEndPoints()

Get a collection of ONLINE Drillbit endpoints by excluding the drillbits that are in QUIESCENT state (drillbits shutting down). Primarily used by the planner to plan queries only on ONLINE drillbits and used by the client during initial connection phase to connect to a drillbit (foreman)

Specified by:

getOnlineEndPoints in class ClusterCoordinator

Returns:

A collection of ONLINE endpoints

getSemaphore

public DistributedSemaphore getSemaphore(String name,
 int maximumLeases)

Specified by:

getSemaphore in class ClusterCoordinator

getOrCreateTransientStore

public <V> TransientStore<V> getOrCreateTransientStore(TransientStoreConfig<V> config)

Description copied from class: ClusterCoordinator

Returns a store instance with the given configuration. Note that implementor might cache the instance so new instance creation is not guaranteed.

Specified by:

getOrCreateTransientStore in class ClusterCoordinator

Type Parameters:

V - value type for this store

Parameters:

config - store configuration