Uses of Class
org.apache.drill.exec.planner.fragment.Wrapper

Packages that use Wrapper

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

Uses of Wrapper in org.apache.drill.exec.planner

Methods in org.apache.drill.exec.planner with parameters of type Wrapper

Modifier and Type	Method and Description
RET	AbstractOpWrapperVisitor.visitExchange(Exchange exchange, Wrapper wrapper)
RET	AbstractOpWrapperVisitor.visitReceivingExchange(Exchange exchange, Wrapper wrapper)
RET	AbstractOpWrapperVisitor.visitSendingExchange(Exchange exchange, Wrapper wrapper)

Uses of Wrapper in org.apache.drill.exec.planner.fragment

Methods in org.apache.drill.exec.planner.fragment that return Wrapper

Modifier and Type	Method and Description
Wrapper	PlanningSet.findRootWrapper(Fragment rootFragment) find the root Wrapper which contains the root Fragment and hold the root wrapper
Wrapper	PlanningSet.get(Fragment node)
Wrapper	Materializer.IndexedFragmentNode.getInfo()
Wrapper	PlanningSet.getRootWrapper()

Methods in org.apache.drill.exec.planner.fragment that return types with arguments of type Wrapper

Modifier and Type	Method and Description
List<Wrapper>	Wrapper.getFragmentDependencies() Get the list of fragements this particular fragment depends on.
Set<Wrapper>	SimpleParallelizer.getRootFragments(PlanningSet planningSet)
Iterator<Wrapper>	PlanningSet.iterator()

Methods in org.apache.drill.exec.planner.fragment with parameters of type Wrapper

Modifier and Type	Method and Description
void	Wrapper.addFragmentDependency(Wrapper dependsOn) Add a parallelization dependency on given fragment.
void	SoftAffinityFragmentParallelizer.parallelizeFragment(Wrapper fragmentWrapper, ParallelizationParameters parameters, Collection<CoordinationProtos.DrillbitEndpoint> activeEndpoints)
void	HardAffinityFragmentParallelizer.parallelizeFragment(Wrapper fragmentWrapper, ParallelizationParameters parameters, Collection<CoordinationProtos.DrillbitEndpoint> activeEndpoints)
void	FragmentParallelizer.parallelizeFragment(Wrapper fragment, ParallelizationParameters parameters, Collection<CoordinationProtos.DrillbitEndpoint> activeEndpoints) Parallelize the given fragment.
protected void	SimpleParallelizer.traverse(Wrapper fragmentWrapper, Consumer<Wrapper> operation) Call operation on each fragment.
Void	StatsCollector.visitGroupScan(GroupScan groupScan, Wrapper wrapper)
Void	StatsCollector.visitOp(PhysicalOperator op, Wrapper wrapper)
Void	MemoryCalculator.visitOp(PhysicalOperator op, Wrapper fragment)
Void	StatsCollector.visitReceivingExchange(Exchange exchange, Wrapper wrapper)
Void	MemoryCalculator.visitReceivingExchange(Exchange exchange, Wrapper fragment)
Void	StatsCollector.visitSendingExchange(Exchange exchange, Wrapper wrapper)
Void	MemoryCalculator.visitSendingExchange(Exchange exchange, Wrapper fragment)
Void	StatsCollector.visitStore(Store store, Wrapper wrapper)

Method parameters in org.apache.drill.exec.planner.fragment with type arguments of type Wrapper

Modifier and Type	Method and Description
void	QueueQueryParallelizer.adjustMemory(PlanningSet planningSet, Set<Wrapper> roots, Collection<CoordinationProtos.DrillbitEndpoint> activeEndpoints) Function called by the SimpleParallelizer to adjust the memory post parallelization.
abstract void	SimpleParallelizer.adjustMemory(PlanningSet planningSet, Set<Wrapper> roots, Collection<CoordinationProtos.DrillbitEndpoint> activeEndpoints)
void	DefaultQueryParallelizer.adjustMemory(PlanningSet planningSet, Set<Wrapper> roots, Collection<CoordinationProtos.DrillbitEndpoint> activeEndpoints)
void	SimpleParallelizer.collectStatsAndParallelizeFragments(PlanningSet planningSet, Set<Wrapper> roots, Collection<CoordinationProtos.DrillbitEndpoint> activeEndpoints) Traverse all the major fragments and parallelize each major fragment based on collected stats.
protected void	SimpleParallelizer.traverse(Wrapper fragmentWrapper, Consumer<Wrapper> operation) Call operation on each fragment.

Constructors in org.apache.drill.exec.planner.fragment with parameters of type Wrapper

Constructor and Description
IndexedFragmentNode(int minorFragmentId, Wrapper info, BiFunction<Wrapper,Integer,CoordinationProtos.DrillbitEndpoint> wrapperToEndpoint, BiFunction<CoordinationProtos.DrillbitEndpoint,PhysicalOperator,Long> memoryReqs)

Constructor parameters in org.apache.drill.exec.planner.fragment with type arguments of type Wrapper

Constructor and Description
IndexedFragmentNode(int minorFragmentId, Wrapper info, BiFunction<Wrapper,Integer,CoordinationProtos.DrillbitEndpoint> wrapperToEndpoint, BiFunction<CoordinationProtos.DrillbitEndpoint,PhysicalOperator,Long> memoryReqs)

Uses of Wrapper in org.apache.drill.exec.work

Methods in org.apache.drill.exec.work that return Wrapper

Modifier and Type	Method and Description
Wrapper	QueryWorkUnit.getRootWrapper()

Constructors in org.apache.drill.exec.work with parameters of type Wrapper

Constructor and Description
QueryWorkUnit(FragmentRoot rootOperator, QueryWorkUnit.MinorFragmentDefn rootFragmentDefn, List<QueryWorkUnit.MinorFragmentDefn> minorFragmentDefns, Wrapper rootWrapper)