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.proto | |
org.apache.drill.exec.rpc.user | |
org.apache.drill.exec.server.rest.profile | |
org.apache.drill.exec.work.foreman |
Modifier and Type | Method and Description |
---|---|
void |
LoggingResultsListener.queryCompleted(UserBitShared.QueryResult.QueryState state) |
Modifier and Type | Method and Description |
---|---|
static UserBitShared.QueryResult.QueryState |
UserBitShared.QueryResult.QueryState.forNumber(int value) |
UserBitShared.QueryResult.QueryState |
UserBitShared.QueryResultOrBuilder.getQueryState()
optional .exec.shared.QueryResult.QueryState query_state = 1; |
UserBitShared.QueryResult.QueryState |
UserBitShared.QueryResult.getQueryState()
optional .exec.shared.QueryResult.QueryState query_state = 1; |
UserBitShared.QueryResult.QueryState |
UserBitShared.QueryResult.Builder.getQueryState()
optional .exec.shared.QueryResult.QueryState query_state = 1; |
UserBitShared.QueryResult.QueryState |
UserBitShared.QueryInfoOrBuilder.getState()
optional .exec.shared.QueryResult.QueryState state = 3; |
UserBitShared.QueryResult.QueryState |
UserBitShared.QueryInfo.getState()
optional .exec.shared.QueryResult.QueryState state = 3; |
UserBitShared.QueryResult.QueryState |
UserBitShared.QueryInfo.Builder.getState()
optional .exec.shared.QueryResult.QueryState state = 3; |
UserBitShared.QueryResult.QueryState |
UserBitShared.QueryProfileOrBuilder.getState()
optional .exec.shared.QueryResult.QueryState state = 8; |
UserBitShared.QueryResult.QueryState |
UserBitShared.QueryProfile.getState()
optional .exec.shared.QueryResult.QueryState state = 8; |
UserBitShared.QueryResult.QueryState |
UserBitShared.QueryProfile.Builder.getState()
optional .exec.shared.QueryResult.QueryState state = 8; |
UserBitShared.QueryResult.QueryState |
UserProtos.QueryPlanFragmentsOrBuilder.getStatus()
required .exec.shared.QueryResult.QueryState status = 1; |
UserBitShared.QueryResult.QueryState |
UserProtos.QueryPlanFragments.getStatus()
required .exec.shared.QueryResult.QueryState status = 1; |
UserBitShared.QueryResult.QueryState |
UserProtos.QueryPlanFragments.Builder.getStatus()
required .exec.shared.QueryResult.QueryState status = 1; |
static UserBitShared.QueryResult.QueryState |
UserBitShared.QueryResult.QueryState.valueOf(com.google.protobuf.Descriptors.EnumValueDescriptor desc) |
static UserBitShared.QueryResult.QueryState |
UserBitShared.QueryResult.QueryState.valueOf(int value)
Deprecated.
Use
forNumber(int) instead. |
static UserBitShared.QueryResult.QueryState |
UserBitShared.QueryResult.QueryState.valueOf(String name)
Returns the enum constant of this type with the specified name.
|
static UserBitShared.QueryResult.QueryState[] |
UserBitShared.QueryResult.QueryState.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<UserBitShared.QueryResult.QueryState> |
UserBitShared.QueryResult.QueryState.internalGetValueMap() |
Modifier and Type | Method and Description |
---|---|
UserBitShared.QueryResult.Builder |
UserBitShared.QueryResult.Builder.setQueryState(UserBitShared.QueryResult.QueryState value)
optional .exec.shared.QueryResult.QueryState query_state = 1; |
UserBitShared.QueryInfo.Builder |
UserBitShared.QueryInfo.Builder.setState(UserBitShared.QueryResult.QueryState value)
optional .exec.shared.QueryResult.QueryState state = 3; |
UserBitShared.QueryProfile.Builder |
UserBitShared.QueryProfile.Builder.setState(UserBitShared.QueryResult.QueryState value)
optional .exec.shared.QueryResult.QueryState state = 8; |
UserProtos.QueryPlanFragments.Builder |
UserProtos.QueryPlanFragments.Builder.setStatus(UserBitShared.QueryResult.QueryState value)
required .exec.shared.QueryResult.QueryState status = 1; |
Modifier and Type | Method and Description |
---|---|
void |
AwaitableUserResultsListener.queryCompleted(UserBitShared.QueryResult.QueryState state) |
void |
UserResultsListener.queryCompleted(UserBitShared.QueryResult.QueryState state)
The query has completed (successful completion or cancellation).
|
Modifier and Type | Method and Description |
---|---|
static String |
ProfileUtil.getQueryStateDisplayName(UserBitShared.QueryResult.QueryState queryState)
Utility method to return display name for query state
|
Modifier and Type | Method and Description |
---|---|
UserBitShared.QueryResult.QueryState |
LoggedQuery.getOutcome() |
UserBitShared.QueryResult.QueryState |
QueryStateProcessor.getState() |
UserBitShared.QueryResult.QueryState |
Foreman.getState() |
Modifier and Type | Method and Description |
---|---|
void |
QueryStateProcessor.addToEventQueue(UserBitShared.QueryResult.QueryState newState,
Exception exception)
Tells the foreman to move to a new state.
This will be added to the end of the event queue and will be processed once the foreman is ready to accept external events. |
void |
Foreman.addToEventQueue(UserBitShared.QueryResult.QueryState state,
Exception exception)
Adds query status in the event queue to process it when foreman is ready.
|
void |
QueryStateProcessor.moveToState(UserBitShared.QueryResult.QueryState newState,
Exception exception)
Moves one query state to another, will fail when requested query state transition is not allowed.
|
void |
QueryStateProcessor.recordNewState(UserBitShared.QueryResult.QueryState newState)
Directly moves query from one state to another and updates ephemeral query store.
|
void |
Foreman.ForemanResult.setCompleted(UserBitShared.QueryResult.QueryState queryState)
Set up the result for a COMPLETED or CANCELED state.
|
Constructor and Description |
---|
LoggedQuery(String queryId,
String schema,
String queryText,
Date start,
Date finish,
UserBitShared.QueryResult.QueryState outcome,
String username,
SocketAddress remoteAddress) |
Copyright © 1970 The Apache Software Foundation. All rights reserved.