Modifier and Type | Method and Description |
---|---|
String |
PhysicalPlanReader.writeJson(OptionList list) |
Modifier and Type | Method and Description |
---|---|
QueryWorkUnit |
QueryParallelizer.generateWorkUnit(OptionList options,
CoordinationProtos.DrillbitEndpoint foremanNode,
UserBitShared.QueryId queryId,
Collection<CoordinationProtos.DrillbitEndpoint> activeEndpoints,
Fragment rootFragment,
UserSession session,
BitControl.QueryContextInformation queryContextInfo)
This is the only function exposed to the consumer of this parallelizer (currently Foreman) to parallelize
the plan.
|
QueryWorkUnit |
SimpleParallelizer.generateWorkUnit(OptionList options,
CoordinationProtos.DrillbitEndpoint foremanNode,
UserBitShared.QueryId queryId,
Collection<CoordinationProtos.DrillbitEndpoint> activeEndpoints,
Fragment rootFragment,
UserSession session,
BitControl.QueryContextInformation queryContextInfo)
The starting function for the whole parallelization and memory computation logic.
|
protected QueryWorkUnit |
SimpleParallelizer.generateWorkUnit(OptionList options,
CoordinationProtos.DrillbitEndpoint foremanNode,
UserBitShared.QueryId queryId,
Fragment rootNode,
PlanningSet planningSet,
UserSession session,
BitControl.QueryContextInformation queryContextInfo) |
List<QueryWorkUnit> |
SimpleParallelizer.getSplitFragments(OptionList options,
CoordinationProtos.DrillbitEndpoint foremanNode,
UserBitShared.QueryId queryId,
Collection<CoordinationProtos.DrillbitEndpoint> activeEndpoints,
PhysicalPlanReader reader,
Fragment rootFragment,
UserSession session,
BitControl.QueryContextInformation queryContextInfo)
Create multiple physical plans from original query planning, it will allow execute them eventually independently
|
Modifier and Type | Method and Description |
---|---|
List<QueryWorkUnit> |
SplittingParallelizer.getSplitFragments(OptionList options,
CoordinationProtos.DrillbitEndpoint foremanNode,
UserBitShared.QueryId queryId,
Collection<CoordinationProtos.DrillbitEndpoint> activeEndpoints,
PhysicalPlanReader reader,
Fragment rootFragment,
UserSession session,
BitControl.QueryContextInformation queryContextInfo)
Create multiple physical plans from original query planning, it will allow execute them eventually independently
|
Modifier and Type | Method and Description |
---|---|
OptionList |
BaseOptionManager.getInternalOptionList() |
@NotNull OptionList |
OptionManager.getInternalOptionList()
Returns all the internal options contained in this option manager.
|
OptionList |
FallbackOptionManager.getOptionList() |
OptionList |
OptionManager.getOptionList()
Gets the list of options managed this manager.
|
OptionList |
QueryOptionManager.getOptionList() |
OptionList |
SystemOptionManager.getOptionList() |
OptionList |
BaseOptionManager.getPublicOptionList() |
@NotNull OptionList |
OptionManager.getPublicOptionList()
Returns all the public options contained in this option manager.
|
Modifier and Type | Method and Description |
---|---|
void |
OptionList.merge(OptionList list) |
Constructor and Description |
---|
FragmentOptionManager(OptionManager systemOptions,
OptionList options) |
Modifier and Type | Method and Description |
---|---|
OptionList |
QueryWorkUnit.MinorFragmentDefn.options() |
Constructor and Description |
---|
MinorFragmentDefn(BitControl.PlanFragment fragment,
FragmentRoot root,
OptionList options) |
Copyright © 1970 The Apache Software Foundation. All rights reserved.