void |
QueueQueryParallelizer.adjustMemory(PlanningSet planningSet,
Set<Wrapper> roots,
Collection<CoordinationProtos.DrillbitEndpoint> activeEndpoints)
Function called by the SimpleParallelizer to adjust the memory post parallelization.
|
abstract void |
SimpleParallelizer.adjustMemory(PlanningSet planningSet,
Set<Wrapper> roots,
Collection<CoordinationProtos.DrillbitEndpoint> activeEndpoints) |
void |
DefaultQueryParallelizer.adjustMemory(PlanningSet planningSet,
Set<Wrapper> roots,
Collection<CoordinationProtos.DrillbitEndpoint> activeEndpoints) |
void |
SimpleParallelizer.collectStatsAndParallelizeFragments(PlanningSet planningSet,
Set<Wrapper> roots,
Collection<CoordinationProtos.DrillbitEndpoint> activeEndpoints)
Traverse all the major fragments and parallelize each major fragment based on
collected stats.
|
protected QueryWorkUnit |
SimpleParallelizer.generateWorkUnit(OptionList options,
CoordinationProtos.DrillbitEndpoint foremanNode,
UserBitShared.QueryId queryId,
Fragment rootNode,
PlanningSet planningSet,
UserSession session,
BitControl.QueryContextInformation queryContextInfo) |
Set<Wrapper> |
SimpleParallelizer.getRootFragments(PlanningSet planningSet) |
void |
SimpleParallelizer.initFragmentWrappers(Fragment rootFragment,
PlanningSet planningSet) |