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.
|
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 © 1970 The Apache Software Foundation. All rights reserved.