Uses of Class
org.apache.drill.exec.proto.UserBitShared.QueryId

Packages that use UserBitShared.QueryId

Package	Description
org.apache.drill
org.apache.drill.exec.client	Java client API for submitting queries and accepting result sets from a Drill server.
org.apache.drill.exec.ops
org.apache.drill.exec.physical.impl.materialize
org.apache.drill.exec.planner.fragment
org.apache.drill.exec.planner.fragment.contrib
org.apache.drill.exec.proto
org.apache.drill.exec.proto.helper
org.apache.drill.exec.record
org.apache.drill.exec.rpc.control
org.apache.drill.exec.rpc.user
org.apache.drill.exec.server.rest
org.apache.drill.exec.server.rest.stream
org.apache.drill.exec.store.parquet
org.apache.drill.exec.work
org.apache.drill.exec.work.batch
org.apache.drill.exec.work.foreman
org.apache.drill.exec.work.foreman.rm	Provides resource management and queuing support for the Drill foreman.
org.apache.drill.exec.work.user
org.apache.drill.test	Provides a variety of test framework tools to simplify Drill unit tests and ad-hoc tests created while developing features.

Uses of UserBitShared.QueryId in org.apache.drill

Methods in org.apache.drill with parameters of type UserBitShared.QueryId

Modifier and Type	Method and Description
void	SingleRowListener.queryIdArrived(UserBitShared.QueryId queryId)

Uses of UserBitShared.QueryId in org.apache.drill.exec.client

Methods in org.apache.drill.exec.client with parameters of type UserBitShared.QueryId

Modifier and Type	Method and Description
DrillRpcFuture<GeneralRPCProtos.Ack>	DrillClient.cancelQuery(UserBitShared.QueryId id)
void	LoggingResultsListener.queryIdArrived(UserBitShared.QueryId queryId)
DrillRpcFuture<GeneralRPCProtos.Ack>	DrillClient.resumeQuery(UserBitShared.QueryId queryId)

Uses of UserBitShared.QueryId in org.apache.drill.exec.ops

Methods in org.apache.drill.exec.ops that return UserBitShared.QueryId

Modifier and Type	Method and Description
UserBitShared.QueryId	FragmentContextImpl.getQueryId()
UserBitShared.QueryId	BaseFragmentContext.getQueryId()
UserBitShared.QueryId	QueryContext.getQueryId()
UserBitShared.QueryId	FragmentContext.getQueryId()

Constructors in org.apache.drill.exec.ops with parameters of type UserBitShared.QueryId

Constructor and Description
QueryContext(UserSession session, DrillbitContext drillbitContext, UserBitShared.QueryId queryId)

Uses of UserBitShared.QueryId in org.apache.drill.exec.physical.impl.materialize

Methods in org.apache.drill.exec.physical.impl.materialize that return UserBitShared.QueryId

Modifier and Type	Method and Description
UserBitShared.QueryId	VectorRecordMaterializer.queryId()
UserBitShared.QueryId	QueryDataPackage.queryId()
UserBitShared.QueryId	QueryDataPackage.EmptyResultsPackage.queryId()
UserBitShared.QueryId	QueryDataPackage.DataPackage.queryId()
UserBitShared.QueryId	RecordMaterializer.queryId()

Constructors in org.apache.drill.exec.physical.impl.materialize with parameters of type UserBitShared.QueryId

Constructor and Description
EmptyResultsPackage(UserBitShared.QueryId queryId)

Uses of UserBitShared.QueryId in org.apache.drill.exec.planner.fragment

Methods in org.apache.drill.exec.planner.fragment with parameters of type UserBitShared.QueryId

Modifier and Type	Method and Description
QueryWorkUnit	QueryParallelizer.generateWorkUnit(OptionList options, CoordinationProtos.DrillbitEndpoint foremanNode, UserBitShared.QueryId queryId, Collection<CoordinationProtos.DrillbitEndpoint> activeEndpoints, Fragment rootFragment, UserSession session, BitControl.QueryContextInformation queryContextInfo) This is the only function exposed to the consumer of this parallelizer (currently Foreman) to parallelize the plan.
QueryWorkUnit	SimpleParallelizer.generateWorkUnit(OptionList options, CoordinationProtos.DrillbitEndpoint foremanNode, UserBitShared.QueryId queryId, Collection<CoordinationProtos.DrillbitEndpoint> activeEndpoints, Fragment rootFragment, UserSession session, BitControl.QueryContextInformation queryContextInfo) The starting function for the whole parallelization and memory computation logic.
protected QueryWorkUnit	SimpleParallelizer.generateWorkUnit(OptionList options, CoordinationProtos.DrillbitEndpoint foremanNode, UserBitShared.QueryId queryId, Fragment rootNode, PlanningSet planningSet, UserSession session, BitControl.QueryContextInformation queryContextInfo)
List<QueryWorkUnit>	SimpleParallelizer.getSplitFragments(OptionList options, CoordinationProtos.DrillbitEndpoint foremanNode, UserBitShared.QueryId queryId, Collection<CoordinationProtos.DrillbitEndpoint> activeEndpoints, PhysicalPlanReader reader, Fragment rootFragment, UserSession session, BitControl.QueryContextInformation queryContextInfo) Create multiple physical plans from original query planning, it will allow execute them eventually independently

Uses of UserBitShared.QueryId in org.apache.drill.exec.planner.fragment.contrib

Methods in org.apache.drill.exec.planner.fragment.contrib with parameters of type UserBitShared.QueryId

Modifier and Type

Method and Description

List<QueryWorkUnit>

SplittingParallelizer.getSplitFragments(OptionList options, CoordinationProtos.DrillbitEndpoint foremanNode, UserBitShared.QueryId queryId, Collection<CoordinationProtos.DrillbitEndpoint> activeEndpoints, PhysicalPlanReader reader, Fragment rootFragment, UserSession session, BitControl.QueryContextInformation queryContextInfo) Create multiple physical plans from original query planning, it will allow execute them eventually independently

Uses of UserBitShared.QueryId in org.apache.drill.exec.proto

Fields in org.apache.drill.exec.proto with type parameters of type UserBitShared.QueryId

Modifier and Type	Field and Description
static com.google.protobuf.Parser<UserBitShared.QueryId>	UserBitShared.QueryId.PARSER Deprecated.

Methods in org.apache.drill.exec.proto that return UserBitShared.QueryId

Modifier and Type	Method and Description
UserBitShared.QueryId	UserBitShared.QueryId.Builder.build()
UserBitShared.QueryId	UserBitShared.QueryId.Builder.buildPartial()
static UserBitShared.QueryId	UserBitShared.QueryId.getDefaultInstance()
UserBitShared.QueryId	UserBitShared.QueryId.getDefaultInstanceForType()
UserBitShared.QueryId	UserBitShared.QueryId.Builder.getDefaultInstanceForType()
UserBitShared.QueryId	UserBitShared.QueryProfileOrBuilder.getId() optional .exec.shared.QueryId id = 1;
UserBitShared.QueryId	UserBitShared.QueryProfile.getId() optional .exec.shared.QueryId id = 1;
UserBitShared.QueryId	UserBitShared.QueryProfile.Builder.getId() optional .exec.shared.QueryId id = 1;
UserBitShared.QueryId	ExecProtos.FragmentHandleOrBuilder.getParentQueryId() optional .exec.shared.QueryId parent_query_id = 4;
UserBitShared.QueryId	ExecProtos.FragmentHandle.getParentQueryId() optional .exec.shared.QueryId parent_query_id = 4;
UserBitShared.QueryId	ExecProtos.FragmentHandle.Builder.getParentQueryId() optional .exec.shared.QueryId parent_query_id = 4;
UserBitShared.QueryId	ExecProtos.FragmentHandleOrBuilder.getQueryId() optional .exec.shared.QueryId query_id = 1;
UserBitShared.QueryId	ExecProtos.FragmentHandle.getQueryId() optional .exec.shared.QueryId query_id = 1;
UserBitShared.QueryId	ExecProtos.FragmentHandle.Builder.getQueryId() optional .exec.shared.QueryId query_id = 1;
UserBitShared.QueryId	BitData.FragmentRecordBatchOrBuilder.getQueryId() optional .exec.shared.QueryId query_id = 1;
UserBitShared.QueryId	BitData.FragmentRecordBatch.getQueryId() optional .exec.shared.QueryId query_id = 1;
UserBitShared.QueryId	BitData.FragmentRecordBatch.Builder.getQueryId() optional .exec.shared.QueryId query_id = 1;
UserBitShared.QueryId	BitData.RuntimeFilterBDefOrBuilder.getQueryId() optional .exec.shared.QueryId query_id = 1;
UserBitShared.QueryId	BitData.RuntimeFilterBDef.getQueryId() optional .exec.shared.QueryId query_id = 1;
UserBitShared.QueryId	BitData.RuntimeFilterBDef.Builder.getQueryId() optional .exec.shared.QueryId query_id = 1;
UserBitShared.QueryId	UserProtos.RequestResultsOrBuilder.getQueryId() optional .exec.shared.QueryId query_id = 1;
UserBitShared.QueryId	UserProtos.RequestResults.getQueryId() optional .exec.shared.QueryId query_id = 1;
UserBitShared.QueryId	UserProtos.RequestResults.Builder.getQueryId() optional .exec.shared.QueryId query_id = 1;
UserBitShared.QueryId	UserProtos.QueryPlanFragmentsOrBuilder.getQueryId() optional .exec.shared.QueryId query_id = 2;
UserBitShared.QueryId	UserProtos.QueryPlanFragments.getQueryId() optional .exec.shared.QueryId query_id = 2;
UserBitShared.QueryId	UserProtos.QueryPlanFragments.Builder.getQueryId() optional .exec.shared.QueryId query_id = 2;
UserBitShared.QueryId	UserBitShared.QueryResultOrBuilder.getQueryId() optional .exec.shared.QueryId query_id = 2;
UserBitShared.QueryId	UserBitShared.QueryResult.getQueryId() optional .exec.shared.QueryId query_id = 2;
UserBitShared.QueryId	UserBitShared.QueryResult.Builder.getQueryId() optional .exec.shared.QueryId query_id = 2;
UserBitShared.QueryId	UserBitShared.QueryDataOrBuilder.getQueryId() optional .exec.shared.QueryId query_id = 1;
UserBitShared.QueryId	UserBitShared.QueryData.getQueryId() optional .exec.shared.QueryId query_id = 1;
UserBitShared.QueryId	UserBitShared.QueryData.Builder.getQueryId() optional .exec.shared.QueryId query_id = 1;
UserBitShared.QueryId	SchemaUserBitShared.QueryId.MessageSchema.newMessage()
static UserBitShared.QueryId	UserBitShared.QueryId.parseDelimitedFrom(InputStream input)
static UserBitShared.QueryId	UserBitShared.QueryId.parseDelimitedFrom(InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static UserBitShared.QueryId	UserBitShared.QueryId.parseFrom(byte[] data)
static UserBitShared.QueryId	UserBitShared.QueryId.parseFrom(byte[] data, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static UserBitShared.QueryId	UserBitShared.QueryId.parseFrom(ByteBuffer data)
static UserBitShared.QueryId	UserBitShared.QueryId.parseFrom(ByteBuffer data, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static UserBitShared.QueryId	UserBitShared.QueryId.parseFrom(com.google.protobuf.ByteString data)
static UserBitShared.QueryId	UserBitShared.QueryId.parseFrom(com.google.protobuf.ByteString data, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static UserBitShared.QueryId	UserBitShared.QueryId.parseFrom(com.google.protobuf.CodedInputStream input)
static UserBitShared.QueryId	UserBitShared.QueryId.parseFrom(com.google.protobuf.CodedInputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static UserBitShared.QueryId	UserBitShared.QueryId.parseFrom(InputStream input)
static UserBitShared.QueryId	UserBitShared.QueryId.parseFrom(InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)

Methods in org.apache.drill.exec.proto that return types with arguments of type UserBitShared.QueryId

Modifier and Type	Method and Description
com.google.protobuf.Parser<UserBitShared.QueryId>	UserBitShared.QueryId.getParserForType()
static com.google.protobuf.Parser<UserBitShared.QueryId>	UserBitShared.QueryId.parser()
Class<UserBitShared.QueryId>	SchemaUserBitShared.QueryId.MessageSchema.typeClass()

Methods in org.apache.drill.exec.proto with parameters of type UserBitShared.QueryId

Modifier and Type	Method and Description
boolean	SchemaUserBitShared.QueryId.MessageSchema.isInitialized(UserBitShared.QueryId message)
void	SchemaUserBitShared.QueryId.MessageSchema.mergeFrom(io.protostuff.Input input, UserBitShared.QueryId message)
UserBitShared.QueryId.Builder	UserBitShared.QueryId.Builder.mergeFrom(UserBitShared.QueryId other)
UserBitShared.QueryProfile.Builder	UserBitShared.QueryProfile.Builder.mergeId(UserBitShared.QueryId value) optional .exec.shared.QueryId id = 1;
ExecProtos.FragmentHandle.Builder	ExecProtos.FragmentHandle.Builder.mergeParentQueryId(UserBitShared.QueryId value) optional .exec.shared.QueryId parent_query_id = 4;
ExecProtos.FragmentHandle.Builder	ExecProtos.FragmentHandle.Builder.mergeQueryId(UserBitShared.QueryId value) optional .exec.shared.QueryId query_id = 1;
BitData.FragmentRecordBatch.Builder	BitData.FragmentRecordBatch.Builder.mergeQueryId(UserBitShared.QueryId value) optional .exec.shared.QueryId query_id = 1;
BitData.RuntimeFilterBDef.Builder	BitData.RuntimeFilterBDef.Builder.mergeQueryId(UserBitShared.QueryId value) optional .exec.shared.QueryId query_id = 1;
UserProtos.RequestResults.Builder	UserProtos.RequestResults.Builder.mergeQueryId(UserBitShared.QueryId value) optional .exec.shared.QueryId query_id = 1;
UserProtos.QueryPlanFragments.Builder	UserProtos.QueryPlanFragments.Builder.mergeQueryId(UserBitShared.QueryId value) optional .exec.shared.QueryId query_id = 2;
UserBitShared.QueryResult.Builder	UserBitShared.QueryResult.Builder.mergeQueryId(UserBitShared.QueryId value) optional .exec.shared.QueryId query_id = 2;
UserBitShared.QueryData.Builder	UserBitShared.QueryData.Builder.mergeQueryId(UserBitShared.QueryId value) optional .exec.shared.QueryId query_id = 1;
static UserBitShared.QueryId.Builder	UserBitShared.QueryId.newBuilder(UserBitShared.QueryId prototype)
UserBitShared.QueryProfile.Builder	UserBitShared.QueryProfile.Builder.setId(UserBitShared.QueryId value) optional .exec.shared.QueryId id = 1;
ExecProtos.FragmentHandle.Builder	ExecProtos.FragmentHandle.Builder.setParentQueryId(UserBitShared.QueryId value) optional .exec.shared.QueryId parent_query_id = 4;
ExecProtos.FragmentHandle.Builder	ExecProtos.FragmentHandle.Builder.setQueryId(UserBitShared.QueryId value) optional .exec.shared.QueryId query_id = 1;
BitData.FragmentRecordBatch.Builder	BitData.FragmentRecordBatch.Builder.setQueryId(UserBitShared.QueryId value) optional .exec.shared.QueryId query_id = 1;
BitData.RuntimeFilterBDef.Builder	BitData.RuntimeFilterBDef.Builder.setQueryId(UserBitShared.QueryId value) optional .exec.shared.QueryId query_id = 1;
UserProtos.RequestResults.Builder	UserProtos.RequestResults.Builder.setQueryId(UserBitShared.QueryId value) optional .exec.shared.QueryId query_id = 1;
UserProtos.QueryPlanFragments.Builder	UserProtos.QueryPlanFragments.Builder.setQueryId(UserBitShared.QueryId value) optional .exec.shared.QueryId query_id = 2;
UserBitShared.QueryResult.Builder	UserBitShared.QueryResult.Builder.setQueryId(UserBitShared.QueryId value) optional .exec.shared.QueryId query_id = 2;
UserBitShared.QueryData.Builder	UserBitShared.QueryData.Builder.setQueryId(UserBitShared.QueryId value) optional .exec.shared.QueryId query_id = 1;
void	SchemaUserBitShared.QueryId.MessageSchema.writeTo(io.protostuff.Output output, UserBitShared.QueryId message)

Uses of UserBitShared.QueryId in org.apache.drill.exec.proto.helper

Methods in org.apache.drill.exec.proto.helper that return UserBitShared.QueryId

Modifier and Type	Method and Description
static UserBitShared.QueryId	QueryIdHelper.getQueryIdFromString(String queryId)

Methods in org.apache.drill.exec.proto.helper with parameters of type UserBitShared.QueryId

Modifier and Type	Method and Description
static String	QueryIdHelper.getQueryId(UserBitShared.QueryId queryId)
static String	QueryIdHelper.getQueryIdentifiers(UserBitShared.QueryId queryId, int majorFragmentId, List<Integer> minorFragmentIds)

Uses of UserBitShared.QueryId in org.apache.drill.exec.record

Methods in org.apache.drill.exec.record with parameters of type UserBitShared.QueryId

Modifier and Type	Method and Description
static FragmentWritableBatch	FragmentWritableBatch.getEmptyBatchWithSchema(boolean isLast, UserBitShared.QueryId queryId, int sendMajorFragmentId, int sendMinorFragmentId, int receiveMajorFragmentId, int receiveMinorFragmentId, BatchSchema schema)
static FragmentWritableBatch	FragmentWritableBatch.getEmptyLast(UserBitShared.QueryId queryId, int sendMajorFragmentId, int sendMinorFragmentId, int receiveMajorFragmentId, int receiveMinorFragmentId)
static FragmentWritableBatch	FragmentWritableBatch.getEmptyLast(UserBitShared.QueryId queryId, int sendMajorFragmentId, int sendMinorFragmentId, int receiveMajorFragmentId, int[] receiveMinorFragmentIds)
static FragmentWritableBatch	FragmentWritableBatch.getEmptyLastWithSchema(UserBitShared.QueryId queryId, int sendMajorFragmentId, int sendMinorFragmentId, int receiveMajorFragmentId, int receiveMinorFragmentId, BatchSchema schema)

Constructors in org.apache.drill.exec.record with parameters of type UserBitShared.QueryId

Constructor and Description
FragmentWritableBatch(boolean isLast, UserBitShared.QueryId queryId, int sendMajorFragmentId, int sendMinorFragmentId, int receiveMajorFragmentId, int[] receiveMinorFragmentIds, WritableBatch batch)
FragmentWritableBatch(boolean isLast, UserBitShared.QueryId queryId, int sendMajorFragmentId, int sendMinorFragmentId, int receiveMajorFragmentId, int receiveMinorFragmentId, WritableBatch batch)

Uses of UserBitShared.QueryId in org.apache.drill.exec.rpc.control

Methods in org.apache.drill.exec.rpc.control that return UserBitShared.QueryId

Modifier and Type	Method and Description
UserBitShared.QueryId	ControlTunnel.RequestProfile.getMessage()
UserBitShared.QueryId	ControlTunnel.CancelQuery.getMessage()

Methods in org.apache.drill.exec.rpc.control with parameters of type UserBitShared.QueryId

Modifier and Type	Method and Description
void	WorkEventBus.addFragmentStatusListener(UserBitShared.QueryId queryId, FragmentStatusListener listener)
void	WorkEventBus.removeFragmentStatusListener(UserBitShared.QueryId queryId)
DrillRpcFuture<GeneralRPCProtos.Ack>	ControlTunnel.requestCancelQuery(UserBitShared.QueryId queryId)
DrillRpcFuture<UserBitShared.QueryProfile>	ControlTunnel.requestQueryProfile(UserBitShared.QueryId queryId)

Constructors in org.apache.drill.exec.rpc.control with parameters of type UserBitShared.QueryId

Constructor and Description
CancelQuery(UserBitShared.QueryId queryId)
RequestProfile(UserBitShared.QueryId queryId)

Uses of UserBitShared.QueryId in org.apache.drill.exec.rpc.user

Methods in org.apache.drill.exec.rpc.user that return types with arguments of type UserBitShared.QueryId

Modifier and Type	Method and Description
RpcOutcomeListener<UserBitShared.QueryId>	QueryResultHandler.getWrappedListener(UserResultsListener resultsListener)

Methods in org.apache.drill.exec.rpc.user with parameters of type UserBitShared.QueryId

Modifier and Type	Method and Description
void	AwaitableUserResultsListener.queryIdArrived(UserBitShared.QueryId queryId)
void	UserResultsListener.queryIdArrived(UserBitShared.QueryId queryId) QueryId is available.

Uses of UserBitShared.QueryId in org.apache.drill.exec.server.rest

Fields in org.apache.drill.exec.server.rest declared as UserBitShared.QueryId

Modifier and Type	Field and Description
protected UserBitShared.QueryId	BaseQueryRunner.queryId

Constructors in org.apache.drill.exec.server.rest with parameters of type UserBitShared.QueryId

Constructor and Description
QueryResult(UserBitShared.QueryId queryId, WebUserConnection webUserConnection, List<Map<String,String>> rows)

Uses of UserBitShared.QueryId in org.apache.drill.exec.server.rest.stream

Methods in org.apache.drill.exec.server.rest.stream with parameters of type UserBitShared.QueryId

Modifier and Type	Method and Description
void	StreamingHttpConnection.onStart(UserBitShared.QueryId queryId, int rowLimit) Provide query info once the query starts.

Uses of UserBitShared.QueryId in org.apache.drill.exec.store.parquet

Methods in org.apache.drill.exec.store.parquet with parameters of type UserBitShared.QueryId

Modifier and Type	Method and Description
void	ParquetResultListener.queryIdArrived(UserBitShared.QueryId queryId)

Uses of UserBitShared.QueryId in org.apache.drill.exec.work

Methods in org.apache.drill.exec.work with parameters of type UserBitShared.QueryId

Modifier and Type	Method and Description
boolean	WorkManager.WorkerBee.cancelForeman(UserBitShared.QueryId queryId, DrillUserPrincipal principal)
Foreman	WorkManager.WorkerBee.getForemanForQueryId(UserBitShared.QueryId queryId)

Uses of UserBitShared.QueryId in org.apache.drill.exec.work.batch

Methods in org.apache.drill.exec.work.batch with parameters of type UserBitShared.QueryId

Modifier and Type	Method and Description
GeneralRPCProtos.Ack	ControlMessageHandler.requestQueryCancel(UserBitShared.QueryId queryId)
UserBitShared.QueryProfile	ControlMessageHandler.requestQueryStatus(UserBitShared.QueryId queryId)

Uses of UserBitShared.QueryId in org.apache.drill.exec.work.foreman

Methods in org.apache.drill.exec.work.foreman that return UserBitShared.QueryId

Modifier and Type	Method and Description
UserBitShared.QueryId	Foreman.getQueryId()

Constructors in org.apache.drill.exec.work.foreman with parameters of type UserBitShared.QueryId

Constructor and Description
Foreman(WorkManager.WorkerBee bee, DrillbitContext drillbitContext, UserClientConnection connection, UserBitShared.QueryId queryId, UserProtos.RunQuery queryRequest) Constructor.
QueryManager(UserBitShared.QueryId queryId, UserProtos.RunQuery runQuery, PersistentStoreProvider storeProvider, ClusterCoordinator coordinator, Foreman foreman)

Uses of UserBitShared.QueryId in org.apache.drill.exec.work.foreman.rm

Methods in org.apache.drill.exec.work.foreman.rm that return UserBitShared.QueryId

Modifier and Type	Method and Description
UserBitShared.QueryId	QueryQueue.QueueTimeoutException.queryId()

Methods in org.apache.drill.exec.work.foreman.rm with parameters of type UserBitShared.QueryId

Modifier and Type	Method and Description
QueryQueue.QueueLease	QueryQueue.enqueue(UserBitShared.QueryId queryId, double cost) Queue a query.
QueryQueue.QueueLease	DistributedQueryQueue.enqueue(UserBitShared.QueryId queryId, double cost) This limits the number of "small" and "large" queries that a Drill cluster will run simultaneously, if queuing is enabled.
QueryQueue.QueueLease	EmbeddedQueryQueue.enqueue(UserBitShared.QueryId queryId, double cost)

Constructors in org.apache.drill.exec.work.foreman.rm with parameters of type UserBitShared.QueryId

Constructor and Description
EmbeddedQueueLease(UserBitShared.QueryId queryId, long queryMemory)
QueueTimeoutException(UserBitShared.QueryId queryId, String queueName, int timeoutMs)

Uses of UserBitShared.QueryId in org.apache.drill.exec.work.user

Methods in org.apache.drill.exec.work.user that return UserBitShared.QueryId

Modifier and Type	Method and Description
UserBitShared.QueryId	UserWorker.submitWork(UserClientConnection connection, UserProtos.RunQuery query)

Methods in org.apache.drill.exec.work.user with parameters of type UserBitShared.QueryId

Modifier and Type	Method and Description
GeneralRPCProtos.Ack	UserWorker.cancelQuery(UserBitShared.QueryId query)
UserProtos.QueryPlanFragments	PlanSplitter.planFragments(DrillbitContext dContext, UserBitShared.QueryId queryId, UserProtos.GetQueryPlanFragments req, UserClientConnection connection) Method to plan the query and return list of fragments it will return query plan "as is" or split plans based on the req setting: split_plan
GeneralRPCProtos.Ack	UserWorker.resumeQuery(UserBitShared.QueryId queryId)

Uses of UserBitShared.QueryId in org.apache.drill.test

Fields in org.apache.drill.test declared as UserBitShared.QueryId

Modifier and Type	Field and Description
UserBitShared.QueryId	BufferingQueryEventListener.QueryEvent.queryId

Methods in org.apache.drill.test that return UserBitShared.QueryId

Modifier and Type	Method and Description
UserBitShared.QueryId	BaseTestQuery.SilentListener.getQueryId()
UserBitShared.QueryId	QueryResultSet.queryId()
UserBitShared.QueryId	QueryBuilder.QuerySummary.queryId()
UserBitShared.QueryId	QueryBatchIterator.queryId()
UserBitShared.QueryId	QueryRowSetIterator.queryId()
UserBitShared.QueryId	QueryRowSetReader.queryId()

Methods in org.apache.drill.test with parameters of type UserBitShared.QueryId

Modifier and Type	Method and Description
void	QueryBuilder.SummaryOnlyQueryEventListener.queryIdArrived(UserBitShared.QueryId queryId)
void	BaseTestQuery.SilentListener.queryIdArrived(UserBitShared.QueryId queryId)
void	BufferingQueryEventListener.queryIdArrived(UserBitShared.QueryId queryId)

Constructors in org.apache.drill.test with parameters of type UserBitShared.QueryId

Constructor and Description
QueryEvent(UserBitShared.QueryId queryId)
QuerySummary(UserBitShared.QueryId queryId, int recordCount, int batchCount, long elapsed, Exception ex)
QuerySummary(UserBitShared.QueryId queryId, int recordCount, int batchCount, long elapsed, UserBitShared.QueryResult.QueryState state)