Modifier and Type | Method and Description |
---|---|
UserSession |
QueryContext.getSession() |
Constructor and Description |
---|
QueryContext(UserSession session,
DrillbitContext drillbitContext,
UserBitShared.QueryId 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
|
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
|
Modifier and Type | Method and Description |
---|---|
UserSession |
SqlConverter.getSession() |
Modifier and Type | Method and Description |
---|---|
UserSession |
UserClientConnection.getSession() |
Modifier and Type | Method and Description |
---|---|
UserSession |
UserSession.Builder.build() |
UserSession |
UserServer.BitToUserConnection.getSession() |
Modifier and Type | Method and Description |
---|---|
void |
UserSession.QueryCountIncrementer.increment(UserSession session) |
void |
InboundImpersonationManager.replaceUserOnSession(String targetName,
UserSession session)
Check if the current session user, as a proxy user, is authorized to impersonate the given target user
based on the system's impersonation policies.
|
Constructor and Description |
---|
SessionOptionManager(OptionManager systemOptions,
UserSession session) |
Modifier and Type | Method and Description |
---|---|
UserSession |
BaseWebUserConnection.getSession() |
UserSession |
WebSessionResources.getSession() |
Modifier and Type | Method and Description |
---|---|
static Runnable |
MetadataProvider.catalogs(UserSession session,
DrillbitContext dContext,
UserProtos.GetCatalogsReq req,
ResponseSender responseSender) |
static Runnable |
MetadataProvider.columns(UserSession session,
DrillbitContext dContext,
UserProtos.GetColumnsReq req,
ResponseSender responseSender) |
static Runnable |
MetadataProvider.schemas(UserSession session,
DrillbitContext dContext,
UserProtos.GetSchemasReq req,
ResponseSender responseSender) |
static Runnable |
MetadataProvider.tables(UserSession session,
DrillbitContext dContext,
UserProtos.GetTablesReq req,
ResponseSender responseSender) |
Constructor and Description |
---|
ServerMetaWorker(UserSession session,
DrillbitContext context,
UserProtos.GetServerMetaReq req,
ResponseSender responseSender) |
Modifier and Type | Method and Description |
---|---|
void |
UserWorker.submitCatalogMetadataWork(UserSession session,
UserProtos.GetCatalogsReq req,
ResponseSender sender) |
void |
UserWorker.submitColumnsMetadataWork(UserSession session,
UserProtos.GetColumnsReq req,
ResponseSender sender) |
void |
UserWorker.submitSchemasMetadataWork(UserSession session,
UserProtos.GetSchemasReq req,
ResponseSender sender) |
void |
UserWorker.submitServerMetadataWork(UserSession session,
UserProtos.GetServerMetaReq req,
ResponseSender sender) |
void |
UserWorker.submitTablesMetadataWork(UserSession session,
UserProtos.GetTablesReq req,
ResponseSender sender) |
Copyright © 1970 The Apache Software Foundation. All rights reserved.