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 and 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 and 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 and Description
static ParallelizationInfo	ParallelizationInfo.UNLIMITED_WIDTH_NO_ENDPOINT_AFFINITY

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

Modifier and Type	Method and 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 and Description
void	ParallelizationInfo.ParallelizationInfoCollector.add(ParallelizationInfo parallelizationInfo)
void	Stats.addParallelizationInfo(ParallelizationInfo parallelizationInfo)