Package | Description |
---|---|
org.apache.drill.exec.client |
Java client API for submitting queries and accepting result sets from a Drill
server.
|
org.apache.drill.exec.coord.local |
A single-node "cluster coordinator" used when running Drill locally.
|
org.apache.drill.exec.coord.zk |
Zookeeper/Curator integration code.
|
org.apache.drill.exec.expr.fn.registry | |
org.apache.drill.exec.ops | |
org.apache.drill.exec.server | |
org.apache.drill.exec.server.rest.profile | |
org.apache.drill.exec.store.sys | |
org.apache.drill.exec.work | |
org.apache.drill.exec.work.foreman |
Constructor and Description |
---|
DrillClient(DrillConfig config,
ClusterCoordinator coordinator) |
DrillClient(DrillConfig config,
ClusterCoordinator coordinator,
boolean isDirect) |
DrillClient(DrillConfig config,
ClusterCoordinator coordinator,
BufferAllocator allocator) |
DrillClient(DrillConfig config,
ClusterCoordinator coordinator,
BufferAllocator allocator,
boolean isDirect) |
Modifier and Type | Class and Description |
---|---|
class |
LocalClusterCoordinator |
Modifier and Type | Class and Description |
---|---|
class |
ZKClusterCoordinator
Manages cluster coordination utilizing zookeeper.
|
Modifier and Type | Method and Description |
---|---|
void |
RemoteFunctionRegistry.init(DrillConfig config,
PersistentStoreProvider storeProvider,
ClusterCoordinator coordinator) |
Modifier and Type | Method and Description |
---|---|
ClusterCoordinator |
ExecutorFragmentContext.getClusterCoordinator() |
ClusterCoordinator |
FragmentContextImpl.getClusterCoordinator() |
Modifier and Type | Method and Description |
---|---|
ClusterCoordinator |
DrillbitContext.getClusterCoordinator() |
ClusterCoordinator |
RemoteServiceSet.getCoordinator() |
Constructor and 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) |
QueryProfileStoreContext(DrillConfig config,
PersistentStoreProvider storeProvider,
ClusterCoordinator coordinator) |
RemoteServiceSet(ClusterCoordinator coordinator) |
Modifier and Type | Method and Description |
---|---|
protected ClusterCoordinator |
ProfileResources.getCoordinator() |
Modifier and Type | Class and Description |
---|---|
class |
PersistentStoreRegistry<C extends ClusterCoordinator> |
Modifier and Type | Method and Description |
---|---|
void |
WorkManager.start(CoordinationProtos.DrillbitEndpoint endpoint,
Controller controller,
DataConnectionCreator data,
ClusterCoordinator coord,
PersistentStoreProvider provider,
PersistentStoreProvider profilesProvider) |
Constructor and Description |
---|
QueryManager(UserBitShared.QueryId queryId,
UserProtos.RunQuery runQuery,
PersistentStoreProvider storeProvider,
ClusterCoordinator coordinator,
Foreman foreman) |
Copyright © 1970 The Apache Software Foundation. All rights reserved.