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

Class SoftAffinityFragmentParallelizer

java.lang.Object

org.apache.drill.exec.planner.fragment.SoftAffinityFragmentParallelizer

All Implemented Interfaces:

FragmentParallelizer

public class SoftAffinityFragmentParallelizer
extends Object
implements FragmentParallelizer

Implementation of FragmentParallelizer where fragment has zero or more endpoints with affinities. Width per node is depended on the affinity to the endpoint and total width (calculated using costs). Based on various factors endpoints which have no affinity can be assigned to run the fragments.

Field Summary

Fields

Modifier and Type	Field	Description
static final SoftAffinityFragmentParallelizer	INSTANCE

Constructor Summary

Constructors

Constructor	Description
SoftAffinityFragmentParallelizer()

Method Summary

Modifier and Type	Method	Description
void	parallelizeFragment(Wrapper fragmentWrapper, ParallelizationParameters parameters, Collection<CoordinationProtos.DrillbitEndpoint> activeEndpoints)	Parallelize the given fragment.

Methods inherited from class java.lang.Object

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

Field Details

INSTANCE

public static final SoftAffinityFragmentParallelizer INSTANCE

Constructor Details

SoftAffinityFragmentParallelizer

public SoftAffinityFragmentParallelizer()

Method Details

parallelizeFragment

public void parallelizeFragment(Wrapper fragmentWrapper,
 ParallelizationParameters parameters,
 Collection<CoordinationProtos.DrillbitEndpoint> activeEndpoints)
                         throws PhysicalOperatorSetupException

Description copied from interface: FragmentParallelizer

Parallelize the given fragment.

Specified by:

parallelizeFragment in interface FragmentParallelizer

Throws:

PhysicalOperatorSetupException