Package org.apache.drill.exec.planner.fragment

Class DefaultQueryParallelizer

java.lang.Object

org.apache.drill.exec.planner.fragment.SimpleParallelizer

org.apache.drill.exec.planner.fragment.DefaultQueryParallelizer

All Implemented Interfaces:

ParallelizationParameters, QueryParallelizer

Direct Known Subclasses:

SplittingParallelizer

public class DefaultQueryParallelizer
extends SimpleParallelizer

Non RM version of the parallelizer. The parallelization logic is fully inherited from SimpleParallelizer. The memory computation of the operators is based on the earlier logic to assign memory for the buffered operators.

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.drill.exec.planner.fragment.SimpleParallelizer

SimpleParallelizer.CountRequiredFragments

Constructor Summary

Constructors

Constructor	Description
DefaultQueryParallelizer(boolean memoryPlanning, long parallelizationThreshold, int maxWidthPerNode, int maxGlobalWidth, double affinityFactor)
DefaultQueryParallelizer(boolean memoryAvailableInPlan, QueryContext queryContext)

Method Summary

Modifier and Type	Method	Description
void	adjustMemory(PlanningSet planningSet, Set<Wrapper> roots, Collection<CoordinationProtos.DrillbitEndpoint> activeEndpoints)
protected BiFunction<CoordinationProtos.DrillbitEndpoint,PhysicalOperator,Long>	getMemory()

Methods inherited from class org.apache.drill.exec.planner.fragment.SimpleParallelizer

collectStatsAndParallelizeFragments, generateWorkUnit, generateWorkUnit, getAffinityFactor, getMaxGlobalWidth, getMaxWidthPerNode, getRootFragments, getSliceTarget, getSplitFragments, initFragmentWrappers, prepareFragmentTree, traverse

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

DefaultQueryParallelizer

public DefaultQueryParallelizer(boolean memoryAvailableInPlan,
 QueryContext queryContext)

DefaultQueryParallelizer

public DefaultQueryParallelizer(boolean memoryPlanning,
 long parallelizationThreshold,
 int maxWidthPerNode,
 int maxGlobalWidth,
 double affinityFactor)

Method Details

adjustMemory

public void adjustMemory(PlanningSet planningSet,
 Set<Wrapper> roots,
 Collection<CoordinationProtos.DrillbitEndpoint> activeEndpoints)

Specified by:

adjustMemory in class SimpleParallelizer

getMemory

protected BiFunction<CoordinationProtos.DrillbitEndpoint,PhysicalOperator,Long> getMemory()

Specified by:

getMemory in class SimpleParallelizer