Constructor and Description |
---|
FragmentContextImpl(DrillbitContext dbContext,
BitControl.PlanFragment fragment,
QueryContext queryContext,
UserClientConnection connection,
FunctionImplementationRegistry funcRegistry)
Create a FragmentContext instance for root fragment.
|
ViewExpansionContext(QueryContext queryContext) |
Constructor and Description |
---|
BasicOptimizationContext(QueryContext c) |
BasicOptimizer(QueryContext queryContext,
UserClientConnection userSession) |
Modifier and Type | Method and Description |
---|---|
boolean |
AbstractBase.isBufferedOperator(QueryContext queryContext)
Any operator that supports spilling should override this method (and return true)
|
boolean |
PhysicalOperator.isBufferedOperator(QueryContext queryContext) |
Modifier and Type | Method and Description |
---|---|
boolean |
ExternalSort.isBufferedOperator(QueryContext queryContext)
The External Sort operator supports spilling
|
boolean |
HashAggregate.isBufferedOperator(QueryContext queryContext)
The Hash Aggregate operator supports spilling
|
boolean |
HashJoinPOP.isBufferedOperator(QueryContext queryContext)
The Hash Aggregate operator supports spilling
|
Modifier and Type | Method and Description |
---|---|
static PhysicalPlan |
DrillStatsTable.direct(QueryContext context,
boolean outcome,
String message,
Object... values) |
static PhysicalPlan |
DrillStatsTable.notRequired(QueryContext context,
String tbl) |
static PhysicalPlan |
DrillStatsTable.notSupported(QueryContext context,
String tbl) |
Modifier and Type | Method and Description |
---|---|
List<PhysicalOperator> |
Fragment.getBufferedOperators(QueryContext queryContext) |
Constructor and Description |
---|
BufferedOpFinder(QueryContext queryContext) |
DefaultQueryParallelizer(boolean memoryAvailableInPlan,
QueryContext queryContext) |
MemoryCalculator(PlanningSet planningSet,
QueryContext context) |
QueueQueryParallelizer(boolean memoryPlanning,
QueryContext queryContext) |
SimpleParallelizer(QueryContext context) |
Constructor and Description |
---|
SplittingParallelizer(boolean doMemoryPlanning,
QueryContext context) |
Modifier and Type | Method and Description |
---|---|
QueryContext |
PhysicalPlanCreator.getContext() |
Constructor and Description |
---|
PhysicalPlanCreator(QueryContext context,
Map<Prel,PrelSequencer.OpId> opIdMap) |
Modifier and Type | Method and Description |
---|---|
static Prel |
RuntimeFilterVisitor.addRuntimeFilter(Prel prel,
QueryContext queryContext) |
Modifier and Type | Method and Description |
---|---|
static PhysicalPlan |
DirectPlan.createDirectPlan(QueryContext context,
boolean result,
String message) |
static <T> PhysicalPlan |
DirectPlan.createDirectPlan(QueryContext context,
T obj) |
static PhysicalPlan |
DrillSqlWorker.getPlan(QueryContext context,
String sql)
Converts sql query string into query physical plan.
|
static PhysicalPlan |
DrillSqlWorker.getPlan(QueryContext context,
String sql,
Pointer<String> textPlan)
Converts sql query string into query physical plan.
|
Constructor and Description |
---|
SqlConverter(QueryContext context) |
Modifier and Type | Field and Description |
---|---|
protected QueryContext |
ViewHandler.context |
protected QueryContext |
DefaultSqlHandler.context |
Modifier and Type | Method and Description |
---|---|
QueryContext |
SqlHandlerConfig.getContext() |
Modifier and Type | Method and Description |
---|---|
static void |
ExplainHandler.printPlan(Prel node,
QueryContext context) |
Constructor and Description |
---|
LogicalExplain(org.apache.calcite.rel.RelNode node,
org.apache.calcite.sql.SqlExplainLevel level,
QueryContext context) |
PhysicalExplain(org.apache.calcite.rel.RelNode node,
PhysicalPlan plan,
org.apache.calcite.sql.SqlExplainLevel level,
QueryContext context) |
ResetOptionHandler(QueryContext context)
Class constructor.
|
SetOptionHandler(QueryContext context) |
SqlHandlerConfig(QueryContext context,
SqlConverter converter) |
UseSchemaHandler(QueryContext context) |
Modifier and Type | Method and Description |
---|---|
static UnsupportedOperatorsVisitor |
UnsupportedOperatorsVisitor.createVisitor(QueryContext context) |
Modifier and Type | Method and Description |
---|---|
QueueAssignmentResult |
ResourcePoolTree.selectAllQueues(QueryContext queryContext) |
QueueAssignmentResult |
ResourcePoolTreeImpl.selectAllQueues(QueryContext queryContext)
Creates
QueueAssignmentResult which contains list of all selected leaf ResourcePools and all the rejected
ResourcePools for the provided query. |
QueryQueueConfig |
ResourcePoolTree.selectOneQueue(QueryContext queryContext,
NodeResources queryMaxNodeResource) |
QueryQueueConfig |
ResourcePoolTreeImpl.selectOneQueue(QueryContext queryContext,
NodeResources queryMaxNodeResource)
Selects a leaf queue out of all the possibles leaf queues returned by
ResourcePoolTree.selectAllQueues(QueryContext) for a given query based on the configured
QueueSelectionPolicy . |
void |
ResourcePool.visitAndSelectPool(QueueAssignmentResult assignmentResult,
QueryContext queryContext)
Evaluates this pool selector to see if the query can be admitted in this pool.
|
void |
ResourcePoolImpl.visitAndSelectPool(QueueAssignmentResult assignmentResult,
QueryContext queryContext)
Used to determine if a ResourcePool is selected for a given query or not.
|
Modifier and Type | Method and Description |
---|---|
abstract ResourcePool |
AbstractQueueSelectionPolicy.selectQueue(List<ResourcePool> allPools,
QueryContext queryContext,
NodeResources maxResourcePerNode) |
ResourcePool |
BestFitQueueSelection.selectQueue(List<ResourcePool> allPools,
QueryContext queryContext,
NodeResources maxResourcePerNode) |
ResourcePool |
DefaultQueueSelection.selectQueue(List<ResourcePool> allPools,
QueryContext queryContext,
NodeResources maxResourcePerNode) |
ResourcePool |
QueueSelectionPolicy.selectQueue(List<ResourcePool> allPools,
QueryContext queryContext,
NodeResources maxResourcePerNode) |
ResourcePool |
RandomQueueSelection.selectQueue(List<ResourcePool> allPools,
QueryContext queryContext,
NodeResources maxResourcePerNode) |
Modifier and Type | Method and Description |
---|---|
abstract boolean |
AbstractResourcePoolSelector.isQuerySelected(QueryContext queryContext) |
boolean |
AclSelector.isQuerySelected(QueryContext queryContext)
Determines if a given query is selected by this ACL selector of a Resource Pool or not.
|
boolean |
AndSelector.isQuerySelected(QueryContext queryContext) |
abstract boolean |
ComplexSelectors.isQuerySelected(QueryContext queryContext) |
boolean |
DefaultSelector.isQuerySelected(QueryContext queryContext) |
boolean |
NotEqualSelector.isQuerySelected(QueryContext queryContext) |
boolean |
OrSelector.isQuerySelected(QueryContext queryContext) |
boolean |
ResourcePoolSelector.isQuerySelected(QueryContext queryContext) |
boolean |
TagSelector.isQuerySelected(QueryContext queryContext) |
Modifier and Type | Method and Description |
---|---|
static List<PhysicalOperator> |
MemoryAllocationUtilities.getBufferedOperators(List<PhysicalOperator> operators,
QueryContext queryContext) |
static void |
MemoryAllocationUtilities.setupBufferedMemoryAllocations(PhysicalPlan plan,
QueryContext queryContext) |
static void |
MemoryAllocationUtilities.setupBufferedOpsMemoryAllocations(boolean planHasMemory,
List<PhysicalOperator> bufferedOperators,
QueryContext queryContext)
Helper method to setup Memory Allocations
|
Modifier and Type | Method and Description |
---|---|
QueryContext |
Foreman.getQueryContext()
Get the QueryContext created for the query.
|
Modifier and Type | Field and Description |
---|---|
protected QueryContext |
ThrottledResourceManager.QueuedResourceAllocator.queryContext |
Modifier and Type | Method and Description |
---|---|
QueryContext |
DefaultResourceManager.DefaultResourceAllocator.getQueryContext() |
QueryContext |
ThrottledResourceManager.QueuedResourceAllocator.getQueryContext() |
Modifier and Type | Method and Description |
---|---|
QueryResourceAllocator |
DefaultResourceManager.newResourceAllocator(QueryContext queryContext) |
QueryResourceAllocator |
DistributedResourceManager.newResourceAllocator(QueryContext queryContext) |
QueryResourceAllocator |
DynamicResourceManager.newResourceAllocator(QueryContext queryContext) |
QueryResourceAllocator |
ResourceManager.newResourceAllocator(QueryContext queryContext)
Create a resource manager to prepare or describe a query.
|
QueryResourceAllocator |
ThrottledResourceManager.newResourceAllocator(QueryContext queryContext) |
Constructor and Description |
---|
DefaultResourceAllocator(QueryContext queryContext) |
QueuedResourceAllocator(ThrottledResourceManager rm,
QueryContext queryContext) |
Copyright © 1970 The Apache Software Foundation. All rights reserved.