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
org.apache.drill.exec.store.phoenix

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	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.
final void	AbstractExchange.setupReceivers(int majorFragmentId, List<CoordinationProtos.DrillbitEndpoint> receiverLocations)
protected void	AbstractExchange.setupReceivers(List<CoordinationProtos.DrillbitEndpoint> receiverLocations)
void	Exchange.setupReceivers(int majorFragmentId, List<CoordinationProtos.DrillbitEndpoint> receiverLocations)	Inform this Exchange node about its receiver locations.
final 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	Description
void	Screen.applyAssignments(List<CoordinationProtos.DrillbitEndpoint> endpoints)
Sender	BroadcastExchange.getSender(int minorFragmentId, PhysicalOperator child)
protected void	SingleMergeExchange.setupReceivers(List<CoordinationProtos.DrillbitEndpoint> receiverLocations)
protected void	UnionExchange.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	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	FragmentParallelizer.parallelizeFragment(Wrapper fragment, ParallelizationParameters parameters, Collection<CoordinationProtos.DrillbitEndpoint> activeEndpoints)	Parallelize the given fragment.
void	HardAffinityFragmentParallelizer.parallelizeFragment(Wrapper fragmentWrapper, ParallelizationParameters parameters, Collection<CoordinationProtos.DrillbitEndpoint> activeEndpoints)
void	SoftAffinityFragmentParallelizer.parallelizeFragment(Wrapper fragmentWrapper, ParallelizationParameters parameters, Collection<CoordinationProtos.DrillbitEndpoint> activeEndpoints)
protected void	SimpleParallelizer.traverse(Wrapper fragmentWrapper, Consumer<Wrapper> operation)	Call operation on each fragment.

Uses of PhysicalOperatorSetupException in org.apache.drill.exec.store.phoenix

Methods in org.apache.drill.exec.store.phoenix that throw PhysicalOperatorSetupException

Modifier and Type	Method	Description
void	PhoenixGroupScan.applyAssignments(List<CoordinationProtos.DrillbitEndpoint> endpoints)