Uses of Interface
org.apache.drill.exec.rpc.UserClientConnection
Packages that use UserClientConnection
Package
Description
-
Uses of UserClientConnection in org.apache.drill.exec.ops
Constructors in org.apache.drill.exec.ops with parameters of type UserClientConnectionModifierConstructorDescriptionAccountingUserConnection(UserClientConnection connection, SendingAccountor sendingAccountor, RpcOutcomeListener<GeneralRPCProtos.Ack> statusHandler) FragmentContextImpl(DrillbitContext dbContext, BitControl.PlanFragment fragment, QueryContext queryContext, UserClientConnection connection, FunctionImplementationRegistry funcRegistry) Create a FragmentContext instance for root fragment.FragmentContextImpl(DrillbitContext dbContext, BitControl.PlanFragment fragment, UserClientConnection connection, FunctionImplementationRegistry funcRegistry) TODO: Remove this constructor when removing the SimpleRootExec (DRILL-2097). -
Uses of UserClientConnection in org.apache.drill.exec.opt
Constructors in org.apache.drill.exec.opt with parameters of type UserClientConnectionModifierConstructorDescriptionBasicOptimizer(QueryContext queryContext, UserClientConnection userSession) -
Uses of UserClientConnection in org.apache.drill.exec.rpc
Classes in org.apache.drill.exec.rpc that implement UserClientConnectionModifier and TypeClassDescriptionclassHelps to run a query and await on the results. -
Uses of UserClientConnection in org.apache.drill.exec.rpc.user
Classes in org.apache.drill.exec.rpc.user that implement UserClientConnectionModifier and TypeClassDescriptionclassRepresents a client connection accepted by Foreman Drillbit's UserServer from a DrillClient. -
Uses of UserClientConnection in org.apache.drill.exec.server.rest
Classes in org.apache.drill.exec.server.rest that implement UserClientConnectionModifier and TypeClassDescriptionclassclassWebUserConnectionWrapperwhich represents theUserClientConnectionbetween WebServer and Foreman, for the WebUser submitting the query.static classMethods in org.apache.drill.exec.server.rest with parameters of type UserClientConnectionModifier and TypeMethodDescriptionprotected voidBaseQueryRunner.startQuery(UserBitShared.QueryType queryType, String query, UserClientConnection clientConn) -
Uses of UserClientConnection in org.apache.drill.exec.server.rest.stream
Classes in org.apache.drill.exec.server.rest.stream that implement UserClientConnectionModifier and TypeClassDescriptionclassStream the results of a query to a REST client as JSON, following the schema defined byQueryResultto maintain backward compatibility. -
Uses of UserClientConnection in org.apache.drill.exec.work.foreman
Constructors in org.apache.drill.exec.work.foreman with parameters of type UserClientConnectionModifierConstructorDescriptionForeman(WorkManager.WorkerBee bee, DrillbitContext drillbitContext, UserClientConnection connection, UserBitShared.QueryId queryId, UserProtos.RunQuery queryRequest) Constructor.FragmentsRunner(WorkManager.WorkerBee bee, UserClientConnection initiatingClient, DrillbitContext drillbitContext, Foreman foreman) -
Uses of UserClientConnection in org.apache.drill.exec.work.prepare
Constructors in org.apache.drill.exec.work.prepare with parameters of type UserClientConnectionModifierConstructorDescriptionPreparedStatementWorker(UserClientConnection connection, UserWorker userWorker, ResponseSender responseSender, UserProtos.CreatePreparedStatementReq req) -
Uses of UserClientConnection in org.apache.drill.exec.work.user
Methods in org.apache.drill.exec.work.user with parameters of type UserClientConnectionModifier and TypeMethodDescriptionUserWorker.getQueryPlan(UserClientConnection connection, UserProtos.GetQueryPlanFragments req) 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_planvoidUserWorker.submitPreparedStatementWork(UserClientConnection connection, UserProtos.CreatePreparedStatementReq req, ResponseSender sender) UserWorker.submitWork(UserClientConnection connection, UserProtos.RunQuery query)