| 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.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 | |
| org.apache.drill.test |
Provides a variety of test framework tools to simplify Drill unit
tests and ad-hoc tests created while developing features.
|
| org.apache.drill.yarn.zk |
Interface between the Application Master and ZooKeeper.
|
| 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 | Method and Description |
|---|---|
void |
RemoteFunctionRegistry.init(DrillConfig config,
PersistentStoreProvider storeProvider,
ClusterCoordinator coordinator) |
| Modifier and Type | Method and Description |
|---|---|
ClusterCoordinator |
FragmentContextImpl.getClusterCoordinator() |
ClusterCoordinator |
ExecutorFragmentContext.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) |
| Modifier and Type | Method and Description |
|---|---|
ClusterCoordinator |
PhysicalOpUnitTestBase.MockExecutorFragmentContext.getClusterCoordinator() |
| Modifier and Type | Class and Description |
|---|---|
class |
ZKClusterCoordinator
Manages cluster coordination utilizing zookeeper.
|
Copyright © 2021 The Apache Software Foundation. All rights reserved.