| Interface | Description |
|---|---|
| FragmentParallelizer |
Generic interface to provide different parallelization strategies for MajorFragments.
|
| FragmentVisitor<T,V> | |
| ParallelizationParameters |
Interface to implement for passing parameters to
FragmentParallelizer. |
| QueryParallelizer |
Parallelizes the query plan.
|
| Class | Description |
|---|---|
| DefaultQueryParallelizer |
Non RM version of the parallelizer.
|
| Fragment | |
| Fragment.BufferedOpFinder | |
| HardAffinityFragmentParallelizer |
Implementation of
FragmentParallelizer where fragment requires
running on a given set of endpoints. |
| MakeFragmentsVisitor |
Responsible for breaking a plan into its constituent Fragments.
|
| Materializer | |
| Materializer.IndexedFragmentNode | |
| MemoryCalculator |
A visitor to compute memory requirements for each operator in a minor fragment.
|
| ParallelizationInfo |
Captures parallelization parameters for a given operator/fragments.
|
| ParallelizationInfo.ParallelizationInfoCollector |
Collects/merges one or more ParallelizationInfo instances.
|
| PlanningSet | |
| QueueQueryParallelizer |
Paralellizer specialized for managing resources for a query based on Queues.
|
| SimpleParallelizer |
The simple parallelizer determines the level of parallelization of a plan
based on the cost of the underlying operations.
|
| SimpleParallelizer.CountRequiredFragments |
Designed to setup initial values for arriving fragment accounting.
|
| SoftAffinityFragmentParallelizer |
Implementation of
FragmentParallelizer where fragment has zero or
more endpoints with affinities. |
| Stats | |
| StatsCollector |
Visitor to collect stats such as cost and parallelization info of operators within a fragment.
|
| TestHardAffinityFragmentParallelizer | |
| Wrapper |
Wrapper class that allows us to add additional information to each fragment
node for planning purposes.
|
| Enum | Description |
|---|---|
| DistributionAffinity |
Describes an operator's endpoint assignment requirements.
|
Copyright © 2021 The Apache Software Foundation. All rights reserved.