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.proto | |
org.apache.drill.yarn.zk |
Interface between the Application Master and ZooKeeper.
|
Modifier and Type | Method and Description |
---|---|
boolean |
ClusterCoordinator.isDrillbitInState(CoordinationProtos.DrillbitEndpoint endpoint,
CoordinationProtos.DrillbitEndpoint.State state) |
abstract ClusterCoordinator.RegistrationHandle |
ClusterCoordinator.update(ClusterCoordinator.RegistrationHandle handle,
CoordinationProtos.DrillbitEndpoint.State state) |
Modifier and Type | Method and Description |
---|---|
ClusterCoordinator.RegistrationHandle |
LocalClusterCoordinator.update(ClusterCoordinator.RegistrationHandle handle,
CoordinationProtos.DrillbitEndpoint.State state)
Update drillbit endpoint state.
|
Modifier and Type | Method and Description |
---|---|
ClusterCoordinator.RegistrationHandle |
ZKClusterCoordinator.update(ClusterCoordinator.RegistrationHandle handle,
CoordinationProtos.DrillbitEndpoint.State state)
Update drillbit endpoint state.
|
Modifier and Type | Method and Description |
---|---|
static CoordinationProtos.DrillbitEndpoint.State |
CoordinationProtos.DrillbitEndpoint.State.forNumber(int value) |
CoordinationProtos.DrillbitEndpoint.State |
CoordinationProtos.DrillbitEndpointOrBuilder.getState()
optional .exec.DrillbitEndpoint.State state = 7; |
CoordinationProtos.DrillbitEndpoint.State |
CoordinationProtos.DrillbitEndpoint.getState()
optional .exec.DrillbitEndpoint.State state = 7; |
CoordinationProtos.DrillbitEndpoint.State |
CoordinationProtos.DrillbitEndpoint.Builder.getState()
optional .exec.DrillbitEndpoint.State state = 7; |
static CoordinationProtos.DrillbitEndpoint.State |
CoordinationProtos.DrillbitEndpoint.State.valueOf(com.google.protobuf.Descriptors.EnumValueDescriptor desc) |
static CoordinationProtos.DrillbitEndpoint.State |
CoordinationProtos.DrillbitEndpoint.State.valueOf(int value)
Deprecated.
Use
forNumber(int) instead. |
static CoordinationProtos.DrillbitEndpoint.State |
CoordinationProtos.DrillbitEndpoint.State.valueOf(String name)
Returns the enum constant of this type with the specified name.
|
static CoordinationProtos.DrillbitEndpoint.State[] |
CoordinationProtos.DrillbitEndpoint.State.values()
Returns an array containing the constants of this enum type, in
the order they are declared.
|
Modifier and Type | Method and Description |
---|---|
static com.google.protobuf.Internal.EnumLiteMap<CoordinationProtos.DrillbitEndpoint.State> |
CoordinationProtos.DrillbitEndpoint.State.internalGetValueMap() |
Modifier and Type | Method and Description |
---|---|
CoordinationProtos.DrillbitEndpoint.Builder |
CoordinationProtos.DrillbitEndpoint.Builder.setState(CoordinationProtos.DrillbitEndpoint.State value)
optional .exec.DrillbitEndpoint.State state = 7; |
Modifier and Type | Method and Description |
---|---|
ClusterCoordinator.RegistrationHandle |
ZKClusterCoordinator.update(ClusterCoordinator.RegistrationHandle handle,
CoordinationProtos.DrillbitEndpoint.State state) |
Copyright © 1970 The Apache Software Foundation. All rights reserved.