| Package | Description |
|---|---|
| org.apache.drill.exec.coord |
Cluster coordination system based on Apache Zookeeper and Curator.
|
| 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.server | |
| org.apache.drill.yarn.zk |
Interface between the Application Master and ZooKeeper.
|
| Modifier and Type | Method and Description |
|---|---|
abstract ClusterCoordinator.RegistrationHandle |
ClusterCoordinator.register(CoordinationProtos.DrillbitEndpoint data) |
abstract ClusterCoordinator.RegistrationHandle |
ClusterCoordinator.update(ClusterCoordinator.RegistrationHandle handle,
CoordinationProtos.DrillbitEndpoint.State state) |
| Modifier and Type | Method and Description |
|---|---|
abstract void |
ClusterCoordinator.unregister(ClusterCoordinator.RegistrationHandle handle) |
abstract ClusterCoordinator.RegistrationHandle |
ClusterCoordinator.update(ClusterCoordinator.RegistrationHandle handle,
CoordinationProtos.DrillbitEndpoint.State state) |
| Modifier and Type | Method and Description |
|---|---|
ClusterCoordinator.RegistrationHandle |
LocalClusterCoordinator.register(CoordinationProtos.DrillbitEndpoint data) |
ClusterCoordinator.RegistrationHandle |
LocalClusterCoordinator.update(ClusterCoordinator.RegistrationHandle handle,
CoordinationProtos.DrillbitEndpoint.State state)
Update drillbit endpoint state.
|
| Modifier and Type | Method and Description |
|---|---|
void |
LocalClusterCoordinator.unregister(ClusterCoordinator.RegistrationHandle handle) |
ClusterCoordinator.RegistrationHandle |
LocalClusterCoordinator.update(ClusterCoordinator.RegistrationHandle handle,
CoordinationProtos.DrillbitEndpoint.State state)
Update drillbit endpoint state.
|
| Modifier and Type | Class and Description |
|---|---|
class |
ZKRegistrationHandle |
| Modifier and Type | Method and Description |
|---|---|
ClusterCoordinator.RegistrationHandle |
ZKClusterCoordinator.register(CoordinationProtos.DrillbitEndpoint data) |
ClusterCoordinator.RegistrationHandle |
ZKClusterCoordinator.update(ClusterCoordinator.RegistrationHandle handle,
CoordinationProtos.DrillbitEndpoint.State state)
Update drillbit endpoint state.
|
| Modifier and Type | Method and Description |
|---|---|
void |
ZKClusterCoordinator.unregister(ClusterCoordinator.RegistrationHandle handle) |
ClusterCoordinator.RegistrationHandle |
ZKClusterCoordinator.update(ClusterCoordinator.RegistrationHandle handle,
CoordinationProtos.DrillbitEndpoint.State state)
Update drillbit endpoint state.
|
| Modifier and Type | Method and Description |
|---|---|
ClusterCoordinator.RegistrationHandle |
Drillbit.getRegistrationHandle() |
| Modifier and Type | Method and Description |
|---|---|
ClusterCoordinator.RegistrationHandle |
ZKClusterCoordinator.register(CoordinationProtos.DrillbitEndpoint data) |
ClusterCoordinator.RegistrationHandle |
ZKClusterCoordinator.update(ClusterCoordinator.RegistrationHandle handle,
CoordinationProtos.DrillbitEndpoint.State state) |
| Modifier and Type | Method and Description |
|---|---|
void |
ZKClusterCoordinator.unregister(ClusterCoordinator.RegistrationHandle handle) |
ClusterCoordinator.RegistrationHandle |
ZKClusterCoordinator.update(ClusterCoordinator.RegistrationHandle handle,
CoordinationProtos.DrillbitEndpoint.State state) |
Copyright © 2021 The Apache Software Foundation. All rights reserved.