Package | Description |
---|---|
org.apache.drill.exec.planner.fragment | |
org.apache.drill.exec.proto | |
org.apache.drill.exec.work.batch |
Modifier and Type | Method and Description |
---|---|
static List<BitControl.Collector> |
SimpleParallelizer.CountRequiredFragments.getCollectors(PhysicalOperator root,
boolean enableDynamicFC) |
Modifier and Type | Method and Description |
---|---|
Void |
SimpleParallelizer.CountRequiredFragments.visitOp(PhysicalOperator op,
List<BitControl.Collector> collectors) |
Void |
SimpleParallelizer.CountRequiredFragments.visitReceiver(Receiver receiver,
List<BitControl.Collector> collectors) |
Modifier and Type | Field and Description |
---|---|
static com.google.protobuf.Parser<BitControl.Collector> |
BitControl.Collector.PARSER
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
BitControl.Collector |
BitControl.Collector.Builder.build() |
BitControl.Collector |
BitControl.Collector.Builder.buildPartial() |
BitControl.Collector |
BitControl.PlanFragmentOrBuilder.getCollector(int index)
repeated .exec.bit.control.Collector collector = 17; |
BitControl.Collector |
BitControl.PlanFragment.getCollector(int index)
repeated .exec.bit.control.Collector collector = 17; |
BitControl.Collector |
BitControl.PlanFragment.Builder.getCollector(int index)
repeated .exec.bit.control.Collector collector = 17; |
static BitControl.Collector |
BitControl.Collector.getDefaultInstance() |
BitControl.Collector |
BitControl.Collector.getDefaultInstanceForType() |
BitControl.Collector |
BitControl.Collector.Builder.getDefaultInstanceForType() |
BitControl.Collector |
SchemaBitControl.Collector.MessageSchema.newMessage() |
static BitControl.Collector |
BitControl.Collector.parseDelimitedFrom(InputStream input) |
static BitControl.Collector |
BitControl.Collector.parseDelimitedFrom(InputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static BitControl.Collector |
BitControl.Collector.parseFrom(byte[] data) |
static BitControl.Collector |
BitControl.Collector.parseFrom(byte[] data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static BitControl.Collector |
BitControl.Collector.parseFrom(ByteBuffer data) |
static BitControl.Collector |
BitControl.Collector.parseFrom(ByteBuffer data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static BitControl.Collector |
BitControl.Collector.parseFrom(com.google.protobuf.ByteString data) |
static BitControl.Collector |
BitControl.Collector.parseFrom(com.google.protobuf.ByteString data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static BitControl.Collector |
BitControl.Collector.parseFrom(com.google.protobuf.CodedInputStream input) |
static BitControl.Collector |
BitControl.Collector.parseFrom(com.google.protobuf.CodedInputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static BitControl.Collector |
BitControl.Collector.parseFrom(InputStream input) |
static BitControl.Collector |
BitControl.Collector.parseFrom(InputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
Modifier and Type | Method and Description |
---|---|
List<BitControl.Collector> |
BitControl.PlanFragmentOrBuilder.getCollectorList()
repeated .exec.bit.control.Collector collector = 17; |
List<BitControl.Collector> |
BitControl.PlanFragment.getCollectorList()
repeated .exec.bit.control.Collector collector = 17; |
List<BitControl.Collector> |
BitControl.PlanFragment.Builder.getCollectorList()
repeated .exec.bit.control.Collector collector = 17; |
com.google.protobuf.Parser<BitControl.Collector> |
BitControl.Collector.getParserForType() |
static com.google.protobuf.Parser<BitControl.Collector> |
BitControl.Collector.parser() |
Class<BitControl.Collector> |
SchemaBitControl.Collector.MessageSchema.typeClass() |
Modifier and Type | Method and Description |
---|---|
BitControl.PlanFragment.Builder |
BitControl.PlanFragment.Builder.addCollector(BitControl.Collector value)
repeated .exec.bit.control.Collector collector = 17; |
BitControl.PlanFragment.Builder |
BitControl.PlanFragment.Builder.addCollector(int index,
BitControl.Collector value)
repeated .exec.bit.control.Collector collector = 17; |
boolean |
SchemaBitControl.Collector.MessageSchema.isInitialized(BitControl.Collector message) |
BitControl.Collector.Builder |
BitControl.Collector.Builder.mergeFrom(BitControl.Collector other) |
void |
SchemaBitControl.Collector.MessageSchema.mergeFrom(io.protostuff.Input input,
BitControl.Collector message) |
static BitControl.Collector.Builder |
BitControl.Collector.newBuilder(BitControl.Collector prototype) |
BitControl.PlanFragment.Builder |
BitControl.PlanFragment.Builder.setCollector(int index,
BitControl.Collector value)
repeated .exec.bit.control.Collector collector = 17; |
void |
SchemaBitControl.Collector.MessageSchema.writeTo(io.protostuff.Output output,
BitControl.Collector message) |
Modifier and Type | Method and Description |
---|---|
BitControl.PlanFragment.Builder |
BitControl.PlanFragment.Builder.addAllCollector(Iterable<? extends BitControl.Collector> values)
repeated .exec.bit.control.Collector collector = 17; |
Constructor and Description |
---|
AbstractDataCollector(AtomicInteger parentAccounter,
int numBuffers,
BitControl.Collector collector,
int bufferCapacity,
FragmentContext context) |
MergingCollector(AtomicInteger parentAccounter,
BitControl.Collector collector,
FragmentContext context) |
PartitionedCollector(AtomicInteger parentAccounter,
BitControl.Collector collector,
FragmentContext context) |
Copyright © 1970 The Apache Software Foundation. All rights reserved.