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 and Description
static SoftAffinityFragmentParallelizer	INSTANCE

Constructor Summary

Constructors

Constructor and Description
SoftAffinityFragmentParallelizer()

Method Summary

Modifier and Type	Method and 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 Detail

INSTANCE

public static final SoftAffinityFragmentParallelizer INSTANCE

Constructor Detail

SoftAffinityFragmentParallelizer

public SoftAffinityFragmentParallelizer()

Method Detail

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