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

Packages that use ParallelizationInfo

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

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

Methods in org.apache.drill.exec.physical.base that return ParallelizationInfo

Modifier and Type	Method	Description
ParallelizationInfo	AbstractExchange.getReceiverParallelizationInfo(List<CoordinationProtos.DrillbitEndpoint> senderFragmentEndpoints)	Default receiver parallelization width range is [1, Integer.MAX_VALUE] and affinity to nodes where sender fragments are running.
ParallelizationInfo	Exchange.getReceiverParallelizationInfo(List<CoordinationProtos.DrillbitEndpoint> senderFragmentEndpoints)	Provide parallelization parameters for receiver side of the exchange.
ParallelizationInfo	AbstractExchange.getSenderParallelizationInfo(List<CoordinationProtos.DrillbitEndpoint> receiverFragmentEndpoints)	Default sender parallelization width range is [1, Integer.MAX_VALUE] and no endpoint affinity
ParallelizationInfo	Exchange.getSenderParallelizationInfo(List<CoordinationProtos.DrillbitEndpoint> receiverFragmentEndpoints)	Provide parallelization parameters for sender side of the exchange.

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

Methods in org.apache.drill.exec.physical.config that return ParallelizationInfo

Modifier and Type	Method	Description
ParallelizationInfo	AbstractDeMuxExchange.getReceiverParallelizationInfo(List<CoordinationProtos.DrillbitEndpoint> senderFragmentEndpoints)
ParallelizationInfo	AbstractMuxExchange.getReceiverParallelizationInfo(List<CoordinationProtos.DrillbitEndpoint> senderFragmentEndpoints)
ParallelizationInfo	SingleMergeExchange.getReceiverParallelizationInfo(List<CoordinationProtos.DrillbitEndpoint> senderFragmentEndpoints)
ParallelizationInfo	UnionExchange.getReceiverParallelizationInfo(List<CoordinationProtos.DrillbitEndpoint> senderFragmentEndpoints)
ParallelizationInfo	AbstractDeMuxExchange.getSenderParallelizationInfo(List<CoordinationProtos.DrillbitEndpoint> receiverFragmentEndpoints)

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

Fields in org.apache.drill.exec.planner.fragment declared as ParallelizationInfo

Modifier and Type	Field	Description
static final ParallelizationInfo	ParallelizationInfo.UNLIMITED_WIDTH_NO_ENDPOINT_AFFINITY

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

Modifier and Type	Method	Description
static ParallelizationInfo	ParallelizationInfo.create(int minWidth, int maxWidth)
static ParallelizationInfo	ParallelizationInfo.create(int minWidth, int maxWidth, List<EndpointAffinity> endpointAffinities)
ParallelizationInfo	ParallelizationInfo.ParallelizationInfoCollector.get()	Get a ParallelizationInfo instance based on the current state of collected info.
ParallelizationInfo	Stats.getParallelizationInfo()

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

Modifier and Type	Method	Description
void	ParallelizationInfo.ParallelizationInfoCollector.add(ParallelizationInfo parallelizationInfo)
void	Stats.addParallelizationInfo(ParallelizationInfo parallelizationInfo)