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

Interface ParallelizationParameters

All Known Subinterfaces:
QueryParallelizer
All Known Implementing Classes:
DefaultQueryParallelizer, QueueQueryParallelizer, SimpleParallelizer, SplittingParallelizer
public interface ParallelizationParameters
Interface to implement for passing parameters to FragmentParallelizer.

  • Method Details

    • getSliceTarget

      long getSliceTarget()
      Returns:
      Configured max width per slice of work.

    • getMaxWidthPerNode

      int getMaxWidthPerNode()
      Returns:
      Configured maximum allowed number of parallelization units per node.

    • getMaxGlobalWidth

      int getMaxGlobalWidth()
      Returns:
      Configured maximum allowed number of parallelization units per all nodes in the cluster.

    • getAffinityFactor

      double getAffinityFactor()
      Returns:
      Factor by which a node with endpoint affinity will be favored while creating assignment.