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) voidLoggingResultsListener.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 QueryWorkUnitSimpleParallelizer.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 QueryWorkUnitSimpleParallelizer.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.PARSERDeprecated.Methods in org.apache.drill.exec.proto that return UserBitShared.QueryIdModifier and TypeMethodDescriptionUserBitShared.QueryId.Builder.build()UserBitShared.QueryId.Builder.buildPartial()static UserBitShared.QueryIdUserBitShared.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.QueryIdUserBitShared.QueryId.parseDelimitedFrom(InputStream input) static UserBitShared.QueryIdUserBitShared.QueryId.parseDelimitedFrom(InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) static UserBitShared.QueryIdUserBitShared.QueryId.parseFrom(byte[] data) static UserBitShared.QueryIdUserBitShared.QueryId.parseFrom(byte[] data, com.google.protobuf.ExtensionRegistryLite extensionRegistry) static UserBitShared.QueryIdUserBitShared.QueryId.parseFrom(com.google.protobuf.ByteString data) static UserBitShared.QueryIdUserBitShared.QueryId.parseFrom(com.google.protobuf.ByteString data, com.google.protobuf.ExtensionRegistryLite extensionRegistry) static UserBitShared.QueryIdUserBitShared.QueryId.parseFrom(com.google.protobuf.CodedInputStream input) static UserBitShared.QueryIdUserBitShared.QueryId.parseFrom(com.google.protobuf.CodedInputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) static UserBitShared.QueryIdUserBitShared.QueryId.parseFrom(InputStream input) static UserBitShared.QueryIdUserBitShared.QueryId.parseFrom(InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) static UserBitShared.QueryIdUserBitShared.QueryId.parseFrom(ByteBuffer data) static UserBitShared.QueryIdUserBitShared.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 TypeMethodDescriptionbooleanSchemaUserBitShared.QueryId.MessageSchema.isInitialized(UserBitShared.QueryId message) voidSchemaUserBitShared.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;voidSchemaUserBitShared.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.QueryIdQueryIdHelper.getQueryIdFromString(String queryId) Methods in org.apache.drill.exec.proto.helper with parameters of type UserBitShared.QueryIdModifier and TypeMethodDescriptionstatic StringQueryIdHelper.getQueryId(UserBitShared.QueryId queryId) static StringQueryIdHelper.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 FragmentWritableBatchFragmentWritableBatch.getEmptyBatchWithSchema(boolean isLast, UserBitShared.QueryId queryId, int sendMajorFragmentId, int sendMinorFragmentId, int receiveMajorFragmentId, int receiveMinorFragmentId, BatchSchema schema) static FragmentWritableBatchFragmentWritableBatch.getEmptyLast(UserBitShared.QueryId queryId, int sendMajorFragmentId, int sendMinorFragmentId, int receiveMajorFragmentId, int receiveMinorFragmentId) static FragmentWritableBatchFragmentWritableBatch.getEmptyLast(UserBitShared.QueryId queryId, int sendMajorFragmentId, int sendMinorFragmentId, int receiveMajorFragmentId, int[] receiveMinorFragmentIds) static FragmentWritableBatchFragmentWritableBatch.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 TypeMethodDescriptionvoidWorkEventBus.addFragmentStatusListener(UserBitShared.QueryId queryId, FragmentStatusListener listener) voidWorkEventBus.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 TypeMethodDescriptionvoidAwaitableUserResultsListener.queryIdArrived(UserBitShared.QueryId queryId) voidBlockingResultsListener.queryIdArrived(UserBitShared.QueryId queryId) voidUserResultsListener.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 TypeMethodDescriptionvoidStreamingHttpConnection.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 TypeMethodDescriptionbooleanWorkManager.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)