| Modifier and Type | Method and Description |
|---|---|
BitControl.QueryContextInformation |
QueryContext.getQueryContextInfo() |
| Constructor and Description |
|---|
ContextInformation(UserBitShared.UserCredentials userCredentials,
BitControl.QueryContextInformation queryContextInfo) |
| 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 | Field and Description |
|---|---|
static com.google.protobuf.Parser<BitControl.QueryContextInformation> |
BitControl.QueryContextInformation.PARSER
Deprecated.
|
| Modifier and Type | Method and Description |
|---|---|
BitControl.QueryContextInformation |
BitControl.QueryContextInformation.Builder.build() |
BitControl.QueryContextInformation |
BitControl.QueryContextInformation.Builder.buildPartial() |
BitControl.QueryContextInformation |
BitControl.PlanFragmentOrBuilder.getContext()
optional .exec.bit.control.QueryContextInformation context = 16; |
BitControl.QueryContextInformation |
BitControl.PlanFragment.getContext()
optional .exec.bit.control.QueryContextInformation context = 16; |
BitControl.QueryContextInformation |
BitControl.PlanFragment.Builder.getContext()
optional .exec.bit.control.QueryContextInformation context = 16; |
static BitControl.QueryContextInformation |
BitControl.QueryContextInformation.getDefaultInstance() |
BitControl.QueryContextInformation |
BitControl.QueryContextInformation.getDefaultInstanceForType() |
BitControl.QueryContextInformation |
BitControl.QueryContextInformation.Builder.getDefaultInstanceForType() |
BitControl.QueryContextInformation |
SchemaBitControl.QueryContextInformation.MessageSchema.newMessage() |
static BitControl.QueryContextInformation |
BitControl.QueryContextInformation.parseDelimitedFrom(InputStream input) |
static BitControl.QueryContextInformation |
BitControl.QueryContextInformation.parseDelimitedFrom(InputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static BitControl.QueryContextInformation |
BitControl.QueryContextInformation.parseFrom(byte[] data) |
static BitControl.QueryContextInformation |
BitControl.QueryContextInformation.parseFrom(byte[] data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static BitControl.QueryContextInformation |
BitControl.QueryContextInformation.parseFrom(ByteBuffer data) |
static BitControl.QueryContextInformation |
BitControl.QueryContextInformation.parseFrom(ByteBuffer data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static BitControl.QueryContextInformation |
BitControl.QueryContextInformation.parseFrom(com.google.protobuf.ByteString data) |
static BitControl.QueryContextInformation |
BitControl.QueryContextInformation.parseFrom(com.google.protobuf.ByteString data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static BitControl.QueryContextInformation |
BitControl.QueryContextInformation.parseFrom(com.google.protobuf.CodedInputStream input) |
static BitControl.QueryContextInformation |
BitControl.QueryContextInformation.parseFrom(com.google.protobuf.CodedInputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static BitControl.QueryContextInformation |
BitControl.QueryContextInformation.parseFrom(InputStream input) |
static BitControl.QueryContextInformation |
BitControl.QueryContextInformation.parseFrom(InputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
| Modifier and Type | Method and Description |
|---|---|
com.google.protobuf.Parser<BitControl.QueryContextInformation> |
BitControl.QueryContextInformation.getParserForType() |
static com.google.protobuf.Parser<BitControl.QueryContextInformation> |
BitControl.QueryContextInformation.parser() |
Class<BitControl.QueryContextInformation> |
SchemaBitControl.QueryContextInformation.MessageSchema.typeClass() |
| Modifier and Type | Method and Description |
|---|---|
boolean |
SchemaBitControl.QueryContextInformation.MessageSchema.isInitialized(BitControl.QueryContextInformation message) |
BitControl.PlanFragment.Builder |
BitControl.PlanFragment.Builder.mergeContext(BitControl.QueryContextInformation value)
optional .exec.bit.control.QueryContextInformation context = 16; |
BitControl.QueryContextInformation.Builder |
BitControl.QueryContextInformation.Builder.mergeFrom(BitControl.QueryContextInformation other) |
void |
SchemaBitControl.QueryContextInformation.MessageSchema.mergeFrom(io.protostuff.Input input,
BitControl.QueryContextInformation message) |
static BitControl.QueryContextInformation.Builder |
BitControl.QueryContextInformation.newBuilder(BitControl.QueryContextInformation prototype) |
BitControl.PlanFragment.Builder |
BitControl.PlanFragment.Builder.setContext(BitControl.QueryContextInformation value)
optional .exec.bit.control.QueryContextInformation context = 16; |
void |
SchemaBitControl.QueryContextInformation.MessageSchema.writeTo(io.protostuff.Output output,
BitControl.QueryContextInformation message) |
| Modifier and Type | Method and Description |
|---|---|
static BitControl.QueryContextInformation |
Utilities.createQueryContextInfo(String defaultSchemaName,
String sessionId)
Create
BitControl.QueryContextInformation with given defaultSchemaName. |
Copyright © 2021 The Apache Software Foundation. All rights reserved.