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

Interface FragmentParallelizer

All Known Implementing Classes:

HardAffinityFragmentParallelizer, SoftAffinityFragmentParallelizer

public interface FragmentParallelizer

Generic interface to provide different parallelization strategies for MajorFragments.

Method Summary

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

Method Details

parallelizeFragment

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

Parallelize the given fragment.

Parameters:

fragment -

parameters -

activeEndpoints -

Throws:

PhysicalOperatorSetupException