Uses of Class
org.apache.drill.exec.proto.UserBitShared.QueryId
Packages that use UserBitShared.QueryId
Package
Description
Java client API for submitting queries and accepting result sets from a Drill
server.
Provides resource management and queuing support for the Drill foreman.
-
Uses of UserBitShared.QueryId in org.apache.drill.exec.client
Methods in org.apache.drill.exec.client with parameters of type UserBitShared.QueryIdModifier and TypeMethodDescriptionDrillClient.cancelQuery
(UserBitShared.QueryId id) void
LoggingResultsListener.queryIdArrived
(UserBitShared.QueryId queryId) 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.QueryIdModifier and TypeMethodDescriptionBaseFragmentContext.getQueryId()
FragmentContext.getQueryId()
FragmentContextImpl.getQueryId()
QueryContext.getQueryId()
Constructors in org.apache.drill.exec.ops with parameters of type UserBitShared.QueryIdModifierConstructorDescriptionQueryContext
(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.QueryIdModifier and TypeMethodDescriptionQueryDataPackage.DataPackage.queryId()
QueryDataPackage.EmptyResultsPackage.queryId()
QueryDataPackage.queryId()
RecordMaterializer.queryId()
VectorRecordMaterializer.queryId()
Constructors in org.apache.drill.exec.physical.impl.materialize with parameters of type UserBitShared.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.QueryIdModifier and TypeMethodDescriptionQueryParallelizer.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.final 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) 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.QueryIdModifier and TypeMethodDescriptionSplittingParallelizer.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.QueryIdModifier and TypeFieldDescriptionstatic final com.google.protobuf.Parser<UserBitShared.QueryId>
UserBitShared.QueryId.PARSER
Deprecated.Methods in org.apache.drill.exec.proto that return UserBitShared.QueryIdModifier and TypeMethodDescriptionUserBitShared.QueryId.Builder.build()
UserBitShared.QueryId.Builder.buildPartial()
static UserBitShared.QueryId
UserBitShared.QueryId.getDefaultInstance()
UserBitShared.QueryId.Builder.getDefaultInstanceForType()
UserBitShared.QueryId.getDefaultInstanceForType()
UserBitShared.QueryProfile.Builder.getId()
optional .exec.shared.QueryId id = 1;
UserBitShared.QueryProfile.getId()
optional .exec.shared.QueryId id = 1;
UserBitShared.QueryProfileOrBuilder.getId()
optional .exec.shared.QueryId id = 1;
ExecProtos.FragmentHandle.Builder.getParentQueryId()
optional .exec.shared.QueryId parent_query_id = 4;
ExecProtos.FragmentHandle.getParentQueryId()
optional .exec.shared.QueryId parent_query_id = 4;
ExecProtos.FragmentHandleOrBuilder.getParentQueryId()
optional .exec.shared.QueryId parent_query_id = 4;
BitData.FragmentRecordBatch.Builder.getQueryId()
optional .exec.shared.QueryId query_id = 1;
BitData.FragmentRecordBatch.getQueryId()
optional .exec.shared.QueryId query_id = 1;
BitData.FragmentRecordBatchOrBuilder.getQueryId()
optional .exec.shared.QueryId query_id = 1;
BitData.RuntimeFilterBDef.Builder.getQueryId()
optional .exec.shared.QueryId query_id = 1;
BitData.RuntimeFilterBDef.getQueryId()
optional .exec.shared.QueryId query_id = 1;
BitData.RuntimeFilterBDefOrBuilder.getQueryId()
optional .exec.shared.QueryId query_id = 1;
ExecProtos.FragmentHandle.Builder.getQueryId()
optional .exec.shared.QueryId query_id = 1;
ExecProtos.FragmentHandle.getQueryId()
optional .exec.shared.QueryId query_id = 1;
ExecProtos.FragmentHandleOrBuilder.getQueryId()
optional .exec.shared.QueryId query_id = 1;
UserBitShared.QueryData.Builder.getQueryId()
optional .exec.shared.QueryId query_id = 1;
UserBitShared.QueryData.getQueryId()
optional .exec.shared.QueryId query_id = 1;
UserBitShared.QueryDataOrBuilder.getQueryId()
optional .exec.shared.QueryId query_id = 1;
UserBitShared.QueryResult.Builder.getQueryId()
optional .exec.shared.QueryId query_id = 2;
UserBitShared.QueryResult.getQueryId()
optional .exec.shared.QueryId query_id = 2;
UserBitShared.QueryResultOrBuilder.getQueryId()
optional .exec.shared.QueryId query_id = 2;
UserProtos.QueryPlanFragments.Builder.getQueryId()
optional .exec.shared.QueryId query_id = 2;
UserProtos.QueryPlanFragments.getQueryId()
optional .exec.shared.QueryId query_id = 2;
UserProtos.QueryPlanFragmentsOrBuilder.getQueryId()
optional .exec.shared.QueryId query_id = 2;
UserProtos.RequestResults.Builder.getQueryId()
optional .exec.shared.QueryId query_id = 1;
UserProtos.RequestResults.getQueryId()
optional .exec.shared.QueryId query_id = 1;
UserProtos.RequestResultsOrBuilder.getQueryId()
optional .exec.shared.QueryId query_id = 1;
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
(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) static UserBitShared.QueryId
UserBitShared.QueryId.parseFrom
(ByteBuffer data) static UserBitShared.QueryId
UserBitShared.QueryId.parseFrom
(ByteBuffer data, com.google.protobuf.ExtensionRegistryLite extensionRegistry) Methods in org.apache.drill.exec.proto that return types with arguments of type UserBitShared.QueryIdModifier and TypeMethodDescriptioncom.google.protobuf.Parser<UserBitShared.QueryId>
UserBitShared.QueryId.getParserForType()
static com.google.protobuf.Parser<UserBitShared.QueryId>
UserBitShared.QueryId.parser()
SchemaUserBitShared.QueryId.MessageSchema.typeClass()
Methods in org.apache.drill.exec.proto with parameters of type UserBitShared.QueryIdModifier and TypeMethodDescriptionboolean
SchemaUserBitShared.QueryId.MessageSchema.isInitialized
(UserBitShared.QueryId message) void
SchemaUserBitShared.QueryId.MessageSchema.mergeFrom
(io.protostuff.Input input, UserBitShared.QueryId message) UserBitShared.QueryId.Builder.mergeFrom
(UserBitShared.QueryId other) UserBitShared.QueryProfile.Builder.mergeId
(UserBitShared.QueryId value) optional .exec.shared.QueryId id = 1;
ExecProtos.FragmentHandle.Builder.mergeParentQueryId
(UserBitShared.QueryId value) optional .exec.shared.QueryId parent_query_id = 4;
BitData.FragmentRecordBatch.Builder.mergeQueryId
(UserBitShared.QueryId value) optional .exec.shared.QueryId query_id = 1;
BitData.RuntimeFilterBDef.Builder.mergeQueryId
(UserBitShared.QueryId value) optional .exec.shared.QueryId query_id = 1;
ExecProtos.FragmentHandle.Builder.mergeQueryId
(UserBitShared.QueryId value) optional .exec.shared.QueryId query_id = 1;
UserBitShared.QueryData.Builder.mergeQueryId
(UserBitShared.QueryId value) optional .exec.shared.QueryId query_id = 1;
UserBitShared.QueryResult.Builder.mergeQueryId
(UserBitShared.QueryId value) optional .exec.shared.QueryId query_id = 2;
UserProtos.QueryPlanFragments.Builder.mergeQueryId
(UserBitShared.QueryId value) optional .exec.shared.QueryId query_id = 2;
UserProtos.RequestResults.Builder.mergeQueryId
(UserBitShared.QueryId value) optional .exec.shared.QueryId query_id = 1;
UserBitShared.QueryId.newBuilder
(UserBitShared.QueryId prototype) UserBitShared.QueryProfile.Builder.setId
(UserBitShared.QueryId value) optional .exec.shared.QueryId id = 1;
ExecProtos.FragmentHandle.Builder.setParentQueryId
(UserBitShared.QueryId value) optional .exec.shared.QueryId parent_query_id = 4;
BitData.FragmentRecordBatch.Builder.setQueryId
(UserBitShared.QueryId value) optional .exec.shared.QueryId query_id = 1;
BitData.RuntimeFilterBDef.Builder.setQueryId
(UserBitShared.QueryId value) optional .exec.shared.QueryId query_id = 1;
ExecProtos.FragmentHandle.Builder.setQueryId
(UserBitShared.QueryId value) optional .exec.shared.QueryId query_id = 1;
UserBitShared.QueryData.Builder.setQueryId
(UserBitShared.QueryId value) optional .exec.shared.QueryId query_id = 1;
UserBitShared.QueryResult.Builder.setQueryId
(UserBitShared.QueryId value) optional .exec.shared.QueryId query_id = 2;
UserProtos.QueryPlanFragments.Builder.setQueryId
(UserBitShared.QueryId value) optional .exec.shared.QueryId query_id = 2;
UserProtos.RequestResults.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.QueryIdModifier and TypeMethodDescriptionstatic UserBitShared.QueryId
QueryIdHelper.getQueryIdFromString
(String queryId) Methods in org.apache.drill.exec.proto.helper with parameters of type UserBitShared.QueryIdModifier and TypeMethodDescriptionstatic 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.QueryIdModifier and TypeMethodDescriptionstatic 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.QueryIdModifierConstructorDescriptionFragmentWritableBatch
(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.QueryIdModifier and TypeMethodDescriptionControlTunnel.CancelQuery.getMessage()
ControlTunnel.RequestProfile.getMessage()
Methods in org.apache.drill.exec.rpc.control with parameters of type UserBitShared.QueryIdModifier and TypeMethodDescriptionvoid
WorkEventBus.addFragmentStatusListener
(UserBitShared.QueryId queryId, FragmentStatusListener listener) void
WorkEventBus.removeFragmentStatusListener
(UserBitShared.QueryId queryId) ControlTunnel.requestCancelQuery
(UserBitShared.QueryId queryId) ControlTunnel.requestQueryProfile
(UserBitShared.QueryId queryId) Constructors in org.apache.drill.exec.rpc.control with parameters of type UserBitShared.QueryIdModifierConstructorDescriptionCancelQuery
(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 UserBitShared.QueryIdMethods in org.apache.drill.exec.rpc.user that return types with arguments of type UserBitShared.QueryIdModifier and TypeMethodDescriptionQueryResultHandler.getWrappedListener
(UserResultsListener resultsListener) Methods in org.apache.drill.exec.rpc.user with parameters of type UserBitShared.QueryIdModifier and TypeMethodDescriptionvoid
AwaitableUserResultsListener.queryIdArrived
(UserBitShared.QueryId queryId) void
BlockingResultsListener.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.QueryIdConstructors in org.apache.drill.exec.server.rest with parameters of type UserBitShared.QueryIdModifierConstructorDescriptionQueryResult
(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.QueryIdModifier and TypeMethodDescriptionvoid
StreamingHttpConnection.onStart
(UserBitShared.QueryId queryId, int rowLimit) Provide query info once the query starts. -
Uses of UserBitShared.QueryId in org.apache.drill.exec.work
Methods in org.apache.drill.exec.work with parameters of type UserBitShared.QueryIdModifier and TypeMethodDescriptionboolean
WorkManager.WorkerBee.cancelForeman
(UserBitShared.QueryId queryId, DrillUserPrincipal principal) 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.QueryIdModifier and TypeMethodDescriptionControlMessageHandler.requestQueryCancel
(UserBitShared.QueryId queryId) 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.QueryIdConstructors in org.apache.drill.exec.work.foreman with parameters of type UserBitShared.QueryIdModifierConstructorDescriptionForeman
(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.QueryIdMethods in org.apache.drill.exec.work.foreman.rm with parameters of type UserBitShared.QueryIdModifier and TypeMethodDescriptionDistributedQueryQueue.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.EmbeddedQueryQueue.enqueue
(UserBitShared.QueryId queryId, double cost) QueryQueue.enqueue
(UserBitShared.QueryId queryId, double cost) Queue a query.Constructors in org.apache.drill.exec.work.foreman.rm with parameters of type UserBitShared.QueryIdModifierConstructorDescriptionEmbeddedQueueLease
(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.QueryIdModifier and TypeMethodDescriptionUserWorker.submitWork
(UserClientConnection connection, UserProtos.RunQuery query) Methods in org.apache.drill.exec.work.user with parameters of type UserBitShared.QueryIdModifier and TypeMethodDescriptionUserWorker.cancelQuery
(UserBitShared.QueryId query) 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_planUserWorker.resumeQuery
(UserBitShared.QueryId queryId)