Uses of Class
org.apache.drill.exec.physical.PhysicalOperatorSetupException

Packages that use PhysicalOperatorSetupException

Package	Description
org.apache.drill.exec.physical.base
org.apache.drill.exec.physical.config
org.apache.drill.exec.planner.fragment

Uses of PhysicalOperatorSetupException in org.apache.drill.exec.physical.base

Methods in org.apache.drill.exec.physical.base that throw PhysicalOperatorSetupException

Modifier and Type	Method and Description
void	GroupScan.applyAssignments(List<CoordinationProtos.DrillbitEndpoint> endpoints)
void	Store.applyAssignments(List<CoordinationProtos.DrillbitEndpoint> endpoints) Inform the Store node about the actual decided DrillbitEndpoint assignments desired for storage purposes.
Sender	Exchange.getSender(int minorFragmentId, PhysicalOperator child) Get the Sender associated with the given minorFragmentId.
Store	Store.getSpecificStore(PhysicalOperator child, int minorFragmentId) Provides full materialized Store operators for execution purposes.
void	AbstractExchange.setupReceivers(int majorFragmentId, List<CoordinationProtos.DrillbitEndpoint> receiverLocations)
void	Exchange.setupReceivers(int majorFragmentId, List<CoordinationProtos.DrillbitEndpoint> receiverLocations) Inform this Exchange node about its receiver locations.
protected void	AbstractExchange.setupReceivers(List<CoordinationProtos.DrillbitEndpoint> receiverLocations)
void	AbstractExchange.setupSenders(int majorFragmentId, List<CoordinationProtos.DrillbitEndpoint> senderLocations)
void	Exchange.setupSenders(int majorFragmentId, List<CoordinationProtos.DrillbitEndpoint> senderLocations) Inform this Exchange node about its sender locations.

Uses of PhysicalOperatorSetupException in org.apache.drill.exec.physical.config

Methods in org.apache.drill.exec.physical.config that throw PhysicalOperatorSetupException

Modifier and Type	Method and Description
void	Screen.applyAssignments(List<CoordinationProtos.DrillbitEndpoint> endpoints)
Sender	BroadcastExchange.getSender(int minorFragmentId, PhysicalOperator child)
protected void	UnionExchange.setupReceivers(List<CoordinationProtos.DrillbitEndpoint> receiverLocations)
protected void	SingleMergeExchange.setupReceivers(List<CoordinationProtos.DrillbitEndpoint> receiverLocations)

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

Methods in org.apache.drill.exec.planner.fragment that throw PhysicalOperatorSetupException

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	Wrapper.assignEndpoints(List<CoordinationProtos.DrillbitEndpoint> assignedEndpoints)
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.
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.