Uses of Class
org.apache.drill.exec.proto.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
Modifier 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
Modifier and TypeMethodDescriptionBaseFragmentContext.getQueryId()
FragmentContext.getQueryId()
FragmentContextImpl.getQueryId()
QueryContext.getQueryId()
ModifierConstructorDescriptionQueryContext
(UserSession session, DrillbitContext drillbitContext, UserBitShared.QueryId queryId) -
Uses of UserBitShared.QueryId in org.apache.drill.exec.physical.impl.materialize
-
Uses of UserBitShared.QueryId in org.apache.drill.exec.planner.fragment
Modifier 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
Modifier 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
Modifier and TypeFieldDescriptionstatic final com.google.protobuf.Parser<UserBitShared.QueryId>
UserBitShared.QueryId.PARSER
Deprecated.Modifier 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) Modifier and TypeMethodDescriptioncom.google.protobuf.Parser<UserBitShared.QueryId>
UserBitShared.QueryId.getParserForType()
static com.google.protobuf.Parser<UserBitShared.QueryId>
UserBitShared.QueryId.parser()
SchemaUserBitShared.QueryId.MessageSchema.typeClass()
Modifier 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
Modifier and TypeMethodDescriptionstatic UserBitShared.QueryId
QueryIdHelper.getQueryIdFromString
(String queryId) Modifier 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
Modifier 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) ModifierConstructorDescriptionFragmentWritableBatch
(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
Modifier and TypeMethodDescriptionControlTunnel.CancelQuery.getMessage()
ControlTunnel.RequestProfile.getMessage()
Modifier 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) ModifierConstructorDescriptionCancelQuery
(UserBitShared.QueryId queryId) RequestProfile
(UserBitShared.QueryId queryId) -
Uses of UserBitShared.QueryId in org.apache.drill.exec.rpc.user
Modifier and TypeMethodDescriptionQueryResultHandler.getWrappedListener
(UserResultsListener resultsListener) Modifier 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
ModifierConstructorDescriptionQueryResult
(UserBitShared.QueryId queryId, WebUserConnection webUserConnection, List<Map<String, String>> rows) -
Uses of UserBitShared.QueryId in org.apache.drill.exec.server.rest.stream
Modifier 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
Modifier 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
Modifier and TypeMethodDescriptionControlMessageHandler.requestQueryCancel
(UserBitShared.QueryId queryId) ControlMessageHandler.requestQueryStatus
(UserBitShared.QueryId queryId) -
Uses of UserBitShared.QueryId in org.apache.drill.exec.work.foreman
ModifierConstructorDescriptionForeman
(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
Modifier 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.ModifierConstructorDescriptionEmbeddedQueueLease
(UserBitShared.QueryId queryId, long queryMemory) QueueTimeoutException
(UserBitShared.QueryId queryId, String queueName, int timeoutMs) -
Uses of UserBitShared.QueryId in org.apache.drill.exec.work.user
Modifier and TypeMethodDescriptionUserWorker.submitWork
(UserClientConnection connection, UserProtos.RunQuery query) Modifier 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)