Package org.apache.drill.exec.server

Class DrillbitContext

java.lang.Object

org.apache.drill.exec.server.DrillbitContext

All Implemented Interfaces:

AutoCloseable

public class DrillbitContext
extends Object
implements AutoCloseable

Constructor Summary

Constructors

Constructor	Description
DrillbitContext(CoordinationProtos.DrillbitEndpoint endpoint, BootStrapContext context, ClusterCoordinator coord, Controller controller, DataConnectionCreator connectionsPool, WorkEventBus workBus, PersistentStoreProvider provider)
DrillbitContext(CoordinationProtos.DrillbitEndpoint endpoint, BootStrapContext context, ClusterCoordinator coord, Controller controller, DataConnectionCreator connectionsPool, WorkEventBus workBus, PersistentStoreProvider provider, PersistentStoreProvider profileStoreProvider)

Method Summary

Modifier and Type	Method	Description
void	close()
AliasRegistryProvider	getAliasRegistryProvider()
BufferAllocator	getAllocator()
AuthenticatorProvider	getAuthProvider()
Collection<CoordinationProtos.DrillbitEndpoint>	getAvailableBits()
io.netty.channel.EventLoopGroup	getBitLoopGroup()
Collection<CoordinationProtos.DrillbitEndpoint>	getBits()
ScanResult	getClasspathScan()
ClusterCoordinator	getClusterCoordinator()
CodeCompiler	getCompiler()
DrillConfig	getConfig()
Controller	getController()
DrillCounters	getCounters()
DataConnectionCreator	getDataConnectionsPool()
CoordinationProtos.DrillbitEndpoint	getEndpoint()
ExecutorService	getExecutor()
FunctionImplementationRegistry	getFunctionImplementationRegistry()
LogicalPlanPersistence	getLpPersistence()
MetastoreRegistry	getMetastoreRegistry()
com.codahale.metrics.MetricRegistry	getMetrics()
OAuthTokenProvider	getOauthTokenProvider()
OperatorCreatorRegistry	getOperatorCreatorRegistry()
DrillOperatorTable	getOperatorTable()	Use the operator table built during startup when "exec.udf.use_dynamic" option is set to false.
SystemOptionManager	getOptionManager()
PhysicalPlanReader	getPlanReader()
QueryProfileStoreContext	getProfileStoreContext()
RemoteFunctionRegistry	getRemoteFunctionRegistry()
ResourceManager	getResourceManager()
ExecutorService	getScanDecodeExecutor()
ExecutorService	getScanExecutor()
SchemaFactory	getSchemaFactory()
StoragePluginRegistry	getStorage()
PersistentStoreProvider	getStoreProvider()
Set<Map.Entry<UserServer.BitToUserConnection,UserServer.BitToUserConnectionConfig>>	getUserConnections()
WorkEventBus	getWorkBus()
boolean	isForeman(CoordinationProtos.DrillbitEndpoint endpoint)
boolean	isForemanOnline()
boolean	isOnline(CoordinationProtos.DrillbitEndpoint endpoint)
void	startRM()	Starts the resource manager.

Methods inherited from class java.lang.Object

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

Constructor Details

DrillbitContext

public DrillbitContext(CoordinationProtos.DrillbitEndpoint endpoint,
 BootStrapContext context,
 ClusterCoordinator coord,
 Controller controller,
 DataConnectionCreator connectionsPool,
 WorkEventBus workBus,
 PersistentStoreProvider provider)

DrillbitContext

public DrillbitContext(CoordinationProtos.DrillbitEndpoint endpoint,
 BootStrapContext context,
 ClusterCoordinator coord,
 Controller controller,
 DataConnectionCreator connectionsPool,
 WorkEventBus workBus,
 PersistentStoreProvider provider,
 PersistentStoreProvider profileStoreProvider)

Method Details

getProfileStoreContext

public QueryProfileStoreContext getProfileStoreContext()

startRM

public void startRM()

Starts the resource manager. Must be called separately from the constructor after the system property mechanism is initialized since the builder will consult system options to determine the proper RM to use.

getFunctionImplementationRegistry

public FunctionImplementationRegistry getFunctionImplementationRegistry()

getWorkBus

public WorkEventBus getWorkBus()

getOptionManager

public SystemOptionManager getOptionManager()

Returns:

the system options manager. It is important to note that this manager only contains options at the "system" level and not "session" level.

getEndpoint

public CoordinationProtos.DrillbitEndpoint getEndpoint()

getConfig

public DrillConfig getConfig()

getAvailableBits

public Collection<CoordinationProtos.DrillbitEndpoint> getAvailableBits()

getBits

public Collection<CoordinationProtos.DrillbitEndpoint> getBits()

isOnline

public boolean isOnline(CoordinationProtos.DrillbitEndpoint endpoint)

isForeman

public boolean isForeman(CoordinationProtos.DrillbitEndpoint endpoint)

isForemanOnline

public boolean isForemanOnline()

getAllocator

public BufferAllocator getAllocator()

getOperatorCreatorRegistry

public OperatorCreatorRegistry getOperatorCreatorRegistry()

getStorage

public StoragePluginRegistry getStorage()

getAliasRegistryProvider

public AliasRegistryProvider getAliasRegistryProvider()

getOauthTokenProvider

public OAuthTokenProvider getOauthTokenProvider()

getBitLoopGroup

public io.netty.channel.EventLoopGroup getBitLoopGroup()

getDataConnectionsPool

public DataConnectionCreator getDataConnectionsPool()

getController

public Controller getController()

getMetrics

public com.codahale.metrics.MetricRegistry getMetrics()

getPlanReader

public PhysicalPlanReader getPlanReader()

getStoreProvider

public PersistentStoreProvider getStoreProvider()

getSchemaFactory

public SchemaFactory getSchemaFactory()

getClusterCoordinator

public ClusterCoordinator getClusterCoordinator()

getCompiler

public CodeCompiler getCompiler()

getExecutor

public ExecutorService getExecutor()

getScanExecutor

public ExecutorService getScanExecutor()

getScanDecodeExecutor

public ExecutorService getScanDecodeExecutor()

getLpPersistence

public LogicalPlanPersistence getLpPersistence()

getClasspathScan

public ScanResult getClasspathScan()

getRemoteFunctionRegistry

public RemoteFunctionRegistry getRemoteFunctionRegistry()

getOperatorTable

public DrillOperatorTable getOperatorTable()

Use the operator table built during startup when "exec.udf.use_dynamic" option is set to false. This operator table has standard SQL functions, operators and drill built-in user defined functions (UDFs). It does not include dynamic user defined functions (UDFs) that get added/removed at run time. This operator table is meant to be used for high throughput, low latency operational queries, for which cost of building operator table is high, both in terms of CPU and heap memory usage.

Returns:

- Operator table

getAuthProvider

public AuthenticatorProvider getAuthProvider()

getUserConnections

public Set<Map.Entry<UserServer.BitToUserConnection,UserServer.BitToUserConnectionConfig>> getUserConnections()

close

public void close()
           throws Exception

Specified by:

close in interface AutoCloseable

Throws:

Exception

getResourceManager

public ResourceManager getResourceManager()

getMetastoreRegistry

public MetastoreRegistry getMetastoreRegistry()

getCounters

public DrillCounters getCounters()