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

Class ParallelizationInfo

java.lang.Object

org.apache.drill.exec.planner.fragment.ParallelizationInfo

public class ParallelizationInfo
extends Object

Captures parallelization parameters for a given operator/fragments. It consists of min and max width of parallelization and affinity to drillbit endpoints.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	ParallelizationInfo.ParallelizationInfoCollector	Collects/merges one or more ParallelizationInfo instances.

Field Summary

Fields

Modifier and Type	Field	Description
static final ParallelizationInfo	UNLIMITED_WIDTH_NO_ENDPOINT_AFFINITY

Method Summary

Modifier and Type	Method	Description
static ParallelizationInfo	create(int minWidth, int maxWidth)
static ParallelizationInfo	create(int minWidth, int maxWidth, List<EndpointAffinity> endpointAffinities)
Map<CoordinationProtos.DrillbitEndpoint,EndpointAffinity>	getEndpointAffinityMap()
int	getMaxWidth()
int	getMinWidth()
String	toString()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Field Details

UNLIMITED_WIDTH_NO_ENDPOINT_AFFINITY

public static final ParallelizationInfo UNLIMITED_WIDTH_NO_ENDPOINT_AFFINITY

Method Details

create

public static ParallelizationInfo create(int minWidth,
 int maxWidth)

create

public static ParallelizationInfo create(int minWidth,
 int maxWidth,
 List<EndpointAffinity> endpointAffinities)

getMinWidth

public int getMinWidth()

getMaxWidth

public int getMaxWidth()

getEndpointAffinityMap

public Map<CoordinationProtos.DrillbitEndpoint,EndpointAffinity> getEndpointAffinityMap()

toString

public String toString()

Overrides:

toString in class Object