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

Class HardAffinityFragmentParallelizer

java.lang.Object

org.apache.drill.exec.planner.fragment.HardAffinityFragmentParallelizer

All Implemented Interfaces:

FragmentParallelizer

public class HardAffinityFragmentParallelizer
extends Object
implements FragmentParallelizer

Implementation of FragmentParallelizer where fragment requires running on a given set of endpoints. Width per node is depended on the affinity to the endpoint and total width (calculated using costs).

Field Summary

Fields

Modifier and Type	Field	Description
static final HardAffinityFragmentParallelizer	INSTANCE

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 HardAffinityFragmentParallelizer INSTANCE

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