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

Class ParallelizationInfo.ParallelizationInfoCollector

java.lang.Object
org.apache.drill.exec.planner.fragment.ParallelizationInfo.ParallelizationInfoCollector
Enclosing class:
ParallelizationInfo
public static class ParallelizationInfo.ParallelizationInfoCollector extends Object
Collects/merges one or more ParallelizationInfo instances.

  • Constructor Details

    • ParallelizationInfoCollector

      public ParallelizationInfoCollector()

  • Method Details

    • add

      public void add(ParallelizationInfo parallelizationInfo)

    • addMaxWidth

      public void addMaxWidth(int newMaxWidth)

    • addMinWidth

      public void addMinWidth(int newMinWidth)

    • addEndpointAffinities

      public void addEndpointAffinities(List<EndpointAffinity> endpointAffinities)

    • get

      public ParallelizationInfo get()
      Get a ParallelizationInfo instance based on the current state of collected info.

    • toString

      public String toString()
      Overrides:
      toString in class Object