| Package | Description |
|---|---|
| org.apache.drill.exec.client |
Java client API for submitting queries and accepting result sets from a Drill
server.
|
| org.apache.drill.exec.fn.interp | |
| org.apache.drill.exec.ops | |
| org.apache.drill.exec.proto | |
| org.apache.drill.exec.work | |
| org.apache.drill.exec.work.batch | |
| org.apache.drill.exec.work.foreman | |
| org.apache.drill.exec.work.fragment | |
| org.apache.drill.test |
Provides a variety of test framework tools to simplify Drill unit
tests and ad-hoc tests created while developing features.
|
| Modifier and Type | Method and Description |
|---|---|
void |
DrillClient.runQuery(UserBitShared.QueryType type,
List<BitControl.PlanFragment> planFragments,
UserResultsListener resultsListener)
Run query based on list of fragments that were supposedly produced during query planning phase.
|
| Modifier and Type | Method and Description |
|---|---|
protected void |
ExpressionInterpreterTest.doTest(String expressionStr,
String[] colNames,
TypeProtos.MajorType[] colTypes,
String[] expectFirstTwoValues,
BitControl.PlanFragment planFragment) |
| Constructor and Description |
|---|
FragmentContextImpl(DrillbitContext dbContext,
BitControl.PlanFragment fragment,
FunctionImplementationRegistry funcRegistry)
Create a FragmentContext instance for non-root fragment.
|
FragmentContextImpl(DrillbitContext dbContext,
BitControl.PlanFragment fragment,
QueryContext queryContext,
UserClientConnection connection,
FunctionImplementationRegistry funcRegistry)
Create a FragmentContext instance for root fragment.
|
FragmentContextImpl(DrillbitContext dbContext,
BitControl.PlanFragment fragment,
UserClientConnection connection,
FunctionImplementationRegistry funcRegistry)
TODO: Remove this constructor when removing the SimpleRootExec (DRILL-2097).
|
| Modifier and Type | Field and Description |
|---|---|
static com.google.protobuf.Parser<BitControl.PlanFragment> |
BitControl.PlanFragment.PARSER
Deprecated.
|
| Modifier and Type | Method and Description |
|---|---|
BitControl.PlanFragment |
BitControl.PlanFragment.Builder.build() |
BitControl.PlanFragment |
BitControl.PlanFragment.Builder.buildPartial() |
static BitControl.PlanFragment |
BitControl.PlanFragment.getDefaultInstance() |
BitControl.PlanFragment |
BitControl.PlanFragment.getDefaultInstanceForType() |
BitControl.PlanFragment |
BitControl.PlanFragment.Builder.getDefaultInstanceForType() |
BitControl.PlanFragment |
BitControl.InitializeFragmentsOrBuilder.getFragment(int index)
repeated .exec.bit.control.PlanFragment fragment = 1; |
BitControl.PlanFragment |
BitControl.InitializeFragments.getFragment(int index)
repeated .exec.bit.control.PlanFragment fragment = 1; |
BitControl.PlanFragment |
BitControl.InitializeFragments.Builder.getFragment(int index)
repeated .exec.bit.control.PlanFragment fragment = 1; |
BitControl.PlanFragment |
UserProtos.QueryPlanFragmentsOrBuilder.getFragments(int index)
repeated .exec.bit.control.PlanFragment fragments = 3; |
BitControl.PlanFragment |
UserProtos.QueryPlanFragments.getFragments(int index)
repeated .exec.bit.control.PlanFragment fragments = 3; |
BitControl.PlanFragment |
UserProtos.QueryPlanFragments.Builder.getFragments(int index)
repeated .exec.bit.control.PlanFragment fragments = 3; |
BitControl.PlanFragment |
UserProtos.RunQueryOrBuilder.getFragments(int index)
Input for query type EXECUTION.
|
BitControl.PlanFragment |
UserProtos.RunQuery.getFragments(int index)
Input for query type EXECUTION.
|
BitControl.PlanFragment |
UserProtos.RunQuery.Builder.getFragments(int index)
Input for query type EXECUTION.
|
BitControl.PlanFragment |
SchemaBitControl.PlanFragment.MessageSchema.newMessage() |
static BitControl.PlanFragment |
BitControl.PlanFragment.parseDelimitedFrom(InputStream input) |
static BitControl.PlanFragment |
BitControl.PlanFragment.parseDelimitedFrom(InputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static BitControl.PlanFragment |
BitControl.PlanFragment.parseFrom(byte[] data) |
static BitControl.PlanFragment |
BitControl.PlanFragment.parseFrom(byte[] data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static BitControl.PlanFragment |
BitControl.PlanFragment.parseFrom(ByteBuffer data) |
static BitControl.PlanFragment |
BitControl.PlanFragment.parseFrom(ByteBuffer data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static BitControl.PlanFragment |
BitControl.PlanFragment.parseFrom(com.google.protobuf.ByteString data) |
static BitControl.PlanFragment |
BitControl.PlanFragment.parseFrom(com.google.protobuf.ByteString data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static BitControl.PlanFragment |
BitControl.PlanFragment.parseFrom(com.google.protobuf.CodedInputStream input) |
static BitControl.PlanFragment |
BitControl.PlanFragment.parseFrom(com.google.protobuf.CodedInputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static BitControl.PlanFragment |
BitControl.PlanFragment.parseFrom(InputStream input) |
static BitControl.PlanFragment |
BitControl.PlanFragment.parseFrom(InputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
| Modifier and Type | Method and Description |
|---|---|
List<BitControl.PlanFragment> |
BitControl.InitializeFragmentsOrBuilder.getFragmentList()
repeated .exec.bit.control.PlanFragment fragment = 1; |
List<BitControl.PlanFragment> |
BitControl.InitializeFragments.getFragmentList()
repeated .exec.bit.control.PlanFragment fragment = 1; |
List<BitControl.PlanFragment> |
BitControl.InitializeFragments.Builder.getFragmentList()
repeated .exec.bit.control.PlanFragment fragment = 1; |
List<BitControl.PlanFragment> |
UserProtos.QueryPlanFragmentsOrBuilder.getFragmentsList()
repeated .exec.bit.control.PlanFragment fragments = 3; |
List<BitControl.PlanFragment> |
UserProtos.QueryPlanFragments.getFragmentsList()
repeated .exec.bit.control.PlanFragment fragments = 3; |
List<BitControl.PlanFragment> |
UserProtos.QueryPlanFragments.Builder.getFragmentsList()
repeated .exec.bit.control.PlanFragment fragments = 3; |
List<BitControl.PlanFragment> |
UserProtos.RunQueryOrBuilder.getFragmentsList()
Input for query type EXECUTION.
|
List<BitControl.PlanFragment> |
UserProtos.RunQuery.getFragmentsList()
Input for query type EXECUTION.
|
List<BitControl.PlanFragment> |
UserProtos.RunQuery.Builder.getFragmentsList()
Input for query type EXECUTION.
|
com.google.protobuf.Parser<BitControl.PlanFragment> |
BitControl.PlanFragment.getParserForType() |
static com.google.protobuf.Parser<BitControl.PlanFragment> |
BitControl.PlanFragment.parser() |
Class<BitControl.PlanFragment> |
SchemaBitControl.PlanFragment.MessageSchema.typeClass() |
| Modifier and Type | Method and Description |
|---|---|
BitControl.InitializeFragments.Builder |
BitControl.InitializeFragments.Builder.addFragment(BitControl.PlanFragment value)
repeated .exec.bit.control.PlanFragment fragment = 1; |
BitControl.InitializeFragments.Builder |
BitControl.InitializeFragments.Builder.addFragment(int index,
BitControl.PlanFragment value)
repeated .exec.bit.control.PlanFragment fragment = 1; |
UserProtos.QueryPlanFragments.Builder |
UserProtos.QueryPlanFragments.Builder.addFragments(BitControl.PlanFragment value)
repeated .exec.bit.control.PlanFragment fragments = 3; |
UserProtos.RunQuery.Builder |
UserProtos.RunQuery.Builder.addFragments(BitControl.PlanFragment value)
Input for query type EXECUTION.
|
UserProtos.QueryPlanFragments.Builder |
UserProtos.QueryPlanFragments.Builder.addFragments(int index,
BitControl.PlanFragment value)
repeated .exec.bit.control.PlanFragment fragments = 3; |
UserProtos.RunQuery.Builder |
UserProtos.RunQuery.Builder.addFragments(int index,
BitControl.PlanFragment value)
Input for query type EXECUTION.
|
boolean |
SchemaBitControl.PlanFragment.MessageSchema.isInitialized(BitControl.PlanFragment message) |
BitControl.PlanFragment.Builder |
BitControl.PlanFragment.Builder.mergeFrom(BitControl.PlanFragment other) |
void |
SchemaBitControl.PlanFragment.MessageSchema.mergeFrom(io.protostuff.Input input,
BitControl.PlanFragment message) |
static BitControl.PlanFragment.Builder |
BitControl.PlanFragment.newBuilder(BitControl.PlanFragment prototype) |
BitControl.InitializeFragments.Builder |
BitControl.InitializeFragments.Builder.setFragment(int index,
BitControl.PlanFragment value)
repeated .exec.bit.control.PlanFragment fragment = 1; |
UserProtos.QueryPlanFragments.Builder |
UserProtos.QueryPlanFragments.Builder.setFragments(int index,
BitControl.PlanFragment value)
repeated .exec.bit.control.PlanFragment fragments = 3; |
UserProtos.RunQuery.Builder |
UserProtos.RunQuery.Builder.setFragments(int index,
BitControl.PlanFragment value)
Input for query type EXECUTION.
|
void |
SchemaBitControl.PlanFragment.MessageSchema.writeTo(io.protostuff.Output output,
BitControl.PlanFragment message) |
| Modifier and Type | Method and Description |
|---|---|
BitControl.InitializeFragments.Builder |
BitControl.InitializeFragments.Builder.addAllFragment(Iterable<? extends BitControl.PlanFragment> values)
repeated .exec.bit.control.PlanFragment fragment = 1; |
UserProtos.QueryPlanFragments.Builder |
UserProtos.QueryPlanFragments.Builder.addAllFragments(Iterable<? extends BitControl.PlanFragment> values)
repeated .exec.bit.control.PlanFragment fragments = 3; |
UserProtos.RunQuery.Builder |
UserProtos.RunQuery.Builder.addAllFragments(Iterable<? extends BitControl.PlanFragment> values)
Input for query type EXECUTION.
|
| Modifier and Type | Method and Description |
|---|---|
BitControl.PlanFragment |
QueryWorkUnit.MinorFragmentDefn.applyPlan(PhysicalPlanReader reader) |
BitControl.PlanFragment |
QueryWorkUnit.MinorFragmentDefn.fragment() |
BitControl.PlanFragment |
QueryWorkUnit.getRootFragment() |
| Modifier and Type | Method and Description |
|---|---|
List<BitControl.PlanFragment> |
QueryWorkUnit.getFragments() |
| Constructor and Description |
|---|
MinorFragmentDefn(BitControl.PlanFragment fragment,
FragmentRoot root,
OptionList options) |
| Modifier and Type | Method and Description |
|---|---|
void |
ControlMessageHandler.startNewFragment(BitControl.PlanFragment fragment,
DrillbitContext drillbitContext)
Start a new fragment on this node.
|
| Constructor and Description |
|---|
IncomingBuffers(BitControl.PlanFragment fragment,
FragmentContext context) |
| Modifier and Type | Method and Description |
|---|---|
void |
FragmentsRunner.setFragmentsInfo(List<BitControl.PlanFragment> planFragments,
BitControl.PlanFragment rootPlanFragment,
FragmentRoot rootOperator) |
| Modifier and Type | Method and Description |
|---|---|
void |
FragmentsRunner.setFragmentsInfo(List<BitControl.PlanFragment> planFragments,
BitControl.PlanFragment rootPlanFragment,
FragmentRoot rootOperator) |
| Modifier and Type | Method and Description |
|---|---|
QueryBuilder |
QueryBuilder.plan(List<BitControl.PlanFragment> planFragments)
Run a physical plan presented as a list of fragments.
|
Copyright © 2021 The Apache Software Foundation. All rights reserved.