Modifier and Type | Class and Description |
---|---|
class |
FragmentContextImpl
This is the core Context which implements all the Context interfaces:
FragmentContext : A context provided to non-exchange
operators.
ExchangeFragmentContext : A context provided to exchange
operators.
RootFragmentContext : A context provided to fragment roots.
ExecutorFragmentContext : A context used by the Drillbit.
The interfaces above expose resources to varying degrees. |
Modifier and Type | Method and Description |
---|---|
CloseableRecordBatch |
SchemalessBatchCreator.getBatch(ExecutorFragmentContext context,
SchemalessScan subScan,
List<RecordBatch> children) |
Modifier and Type | Method and Description |
---|---|
MergingRecordBatch |
MergingReceiverCreator.getBatch(ExecutorFragmentContext context,
MergingReceiverPOP receiver,
List<RecordBatch> children) |
CloseableRecordBatch |
BatchCreator.getBatch(ExecutorFragmentContext context,
T config,
List<RecordBatch> children) |
static RootExec |
ImplCreator.getExec(ExecutorFragmentContext context,
FragmentRoot root)
Create and return fragment RootExec for given FragmentRoot.
|
RecordBatch |
ImplCreator.getRecordBatch(PhysicalOperator op,
ExecutorFragmentContext context)
Create a RecordBatch and its children for given PhysicalOperator
|
RootExec |
ScreenCreator.getRoot(ExecutorFragmentContext context,
Screen config,
List<RecordBatch> children) |
RootExec |
SingleSenderCreator.getRoot(ExecutorFragmentContext context,
SingleSender config,
List<RecordBatch> children) |
RootExec |
RootCreator.getRoot(ExecutorFragmentContext context,
T config,
List<RecordBatch> children) |
Modifier and Type | Method and Description |
---|---|
HashAggBatch |
HashAggBatchCreator.getBatch(ExecutorFragmentContext context,
HashAggregate config,
List<RecordBatch> children) |
StreamingAggBatch |
StreamingAggBatchCreator.getBatch(ExecutorFragmentContext context,
StreamingAggregate config,
List<RecordBatch> children) |
Modifier and Type | Method and Description |
---|---|
RootExec |
BroadcastSenderCreator.getRoot(ExecutorFragmentContext context,
BroadcastSender config,
List<RecordBatch> children) |
Modifier and Type | Method and Description |
---|---|
FilterRecordBatch |
FilterBatchCreator.getBatch(ExecutorFragmentContext context,
Filter config,
List<RecordBatch> children) |
CloseableRecordBatch |
RuntimeFilterBatchCreator.getBatch(ExecutorFragmentContext context,
RuntimeFilterPOP config,
List<RecordBatch> children) |
Modifier and Type | Method and Description |
---|---|
FlattenRecordBatch |
FlattenBatchCreator.getBatch(ExecutorFragmentContext context,
FlattenPOP config,
List<RecordBatch> children) |
Modifier and Type | Method and Description |
---|---|
HashJoinBatch |
HashJoinBatchCreator.getBatch(ExecutorFragmentContext context,
HashJoinPOP config,
List<RecordBatch> children) |
LateralJoinBatch |
LateralJoinBatchCreator.getBatch(ExecutorFragmentContext context,
LateralJoinPOP config,
List<RecordBatch> children) |
MergeJoinBatch |
MergeJoinCreator.getBatch(ExecutorFragmentContext context,
MergeJoinPOP config,
List<RecordBatch> children) |
NestedLoopJoinBatch |
NestedLoopJoinBatchCreator.getBatch(ExecutorFragmentContext context,
NestedLoopJoinPOP config,
List<RecordBatch> children) |
RowKeyJoinBatch |
RowKeyJoinBatchCreator.getBatch(ExecutorFragmentContext context,
RowKeyJoinPOP config,
List<RecordBatch> children) |
Modifier and Type | Method and Description |
---|---|
LimitRecordBatch |
LimitBatchCreator.getBatch(ExecutorFragmentContext context,
Limit config,
List<RecordBatch> children) |
PartitionLimitRecordBatch |
PartitionLimitBatchCreator.getBatch(ExecutorFragmentContext context,
PartitionLimit config,
List<RecordBatch> children) |
Modifier and Type | Method and Description |
---|---|
CloseableRecordBatch |
MetadataControllerBatchCreator.getBatch(ExecutorFragmentContext context,
MetadataControllerPOP config,
List<RecordBatch> children) |
CloseableRecordBatch |
MetadataHandlerBatchCreator.getBatch(ExecutorFragmentContext context,
MetadataHandlerPOP config,
List<RecordBatch> children) |
CloseableRecordBatch |
MetadataHashAggBatchCreator.getBatch(ExecutorFragmentContext context,
MetadataHashAggPOP config,
List<RecordBatch> children) |
CloseableRecordBatch |
MetadataStreamAggBatchCreator.getBatch(ExecutorFragmentContext context,
MetadataStreamAggPOP config,
List<RecordBatch> children) |
Modifier and Type | Method and Description |
---|---|
RootExec |
OrderedPartitionSenderCreator.getRoot(ExecutorFragmentContext context,
OrderedPartitionSender config,
List<RecordBatch> children) |
Modifier and Type | Method and Description |
---|---|
RootExec |
PartitionSenderCreator.getRoot(ExecutorFragmentContext context,
HashPartitionSender config,
List<RecordBatch> children) |
Modifier and Type | Method and Description |
---|---|
ProducerConsumerBatch |
ProducerConsumerBatchCreator.getBatch(ExecutorFragmentContext context,
ProducerConsumer config,
List<RecordBatch> children) |
Modifier and Type | Method and Description |
---|---|
ProjectRecordBatch |
ComplexToJsonBatchCreator.getBatch(ExecutorFragmentContext context,
ComplexToJson flatten,
List<RecordBatch> children) |
ProjectRecordBatch |
ProjectBatchCreator.getBatch(ExecutorFragmentContext context,
Project config,
List<RecordBatch> children) |
Modifier and Type | Method and Description |
---|---|
RootExec |
RangePartitionSenderCreator.getRoot(ExecutorFragmentContext context,
RangePartitionSender config,
List<RecordBatch> children) |
Modifier and Type | Method and Description |
---|---|
SortBatch |
SortBatchCreator.getBatch(ExecutorFragmentContext context,
Sort config,
List<RecordBatch> children) |
Modifier and Type | Method and Description |
---|---|
CloseableRecordBatch |
StatisticsAggBatchCreator.getBatch(ExecutorFragmentContext context,
StatisticsAggregate config,
List<RecordBatch> children) |
CloseableRecordBatch |
StatisticsMergeBatchCreator.getBatch(ExecutorFragmentContext context,
StatisticsMerge config,
List<RecordBatch> children) |
Modifier and Type | Method and Description |
---|---|
RemovingRecordBatch |
SVRemoverCreator.getBatch(ExecutorFragmentContext context,
SelectionVectorRemover config,
List<RecordBatch> children) |
Modifier and Type | Method and Description |
---|---|
TopNBatch |
TopNSortBatchCreator.getBatch(ExecutorFragmentContext context,
TopN config,
List<RecordBatch> children) |
Modifier and Type | Method and Description |
---|---|
TraceRecordBatch |
TraceBatchCreator.getBatch(ExecutorFragmentContext context,
Trace config,
List<RecordBatch> children) |
Modifier and Type | Method and Description |
---|---|
UnionAllRecordBatch |
UnionAllBatchCreator.getBatch(ExecutorFragmentContext context,
UnionAll config,
List<RecordBatch> children) |
Modifier and Type | Method and Description |
---|---|
UnnestRecordBatch |
UnnestBatchCreator.getBatch(ExecutorFragmentContext context,
UnnestPOP config,
List<RecordBatch> children) |
Modifier and Type | Method and Description |
---|---|
UnorderedReceiverBatch |
UnorderedReceiverCreator.getBatch(ExecutorFragmentContext context,
UnorderedReceiver receiver,
List<RecordBatch> children) |
Modifier and Type | Method and Description |
---|---|
CloseableRecordBatch |
UnpivotMapsBatchCreator.getBatch(ExecutorFragmentContext context,
UnpivotMaps config,
List<RecordBatch> children) |
Modifier and Type | Method and Description |
---|---|
IteratorValidatorBatchIterator |
IteratorValidatorCreator.getBatch(ExecutorFragmentContext context,
IteratorValidator config,
List<RecordBatch> children) |
Modifier and Type | Method and Description |
---|---|
ScanBatch |
ValuesBatchCreator.getBatch(ExecutorFragmentContext context,
Values config,
List<RecordBatch> children) |
Modifier and Type | Method and Description |
---|---|
WindowFrameRecordBatch |
WindowFrameBatchCreator.getBatch(ExecutorFragmentContext context,
WindowPOP config,
List<RecordBatch> children) |
Modifier and Type | Method and Description |
---|---|
AbstractRecordBatch<ExternalSort> |
ExternalSortBatchCreator.getBatch(ExecutorFragmentContext context,
ExternalSort config,
List<RecordBatch> children) |
Modifier and Type | Method and Description |
---|---|
CloseableRecordBatch |
EasyReaderBatchCreator.getBatch(ExecutorFragmentContext context,
EasySubScan config,
List<RecordBatch> children) |
CloseableRecordBatch |
EasyWriterBatchCreator.getBatch(ExecutorFragmentContext context,
EasyWriter config,
List<RecordBatch> children) |
Modifier and Type | Method and Description |
---|---|
ScanBatch |
DirectBatchCreator.getBatch(ExecutorFragmentContext context,
DirectSubScan config,
List<RecordBatch> children) |
Modifier and Type | Method and Description |
---|---|
CloseableRecordBatch |
DruidScanBatchCreator.getBatch(ExecutorFragmentContext context,
DruidSubScan subScan,
List<RecordBatch> children) |
Modifier and Type | Method and Description |
---|---|
ScanBatch |
HBaseScanBatchCreator.getBatch(ExecutorFragmentContext context,
HBaseSubScan subScan,
List<RecordBatch> children) |
Modifier and Type | Method and Description |
---|---|
CloseableRecordBatch |
HiveDrillNativeParquetScanBatchCreator.getBatch(ExecutorFragmentContext context,
HiveDrillNativeParquetRowGroupScan rowGroupScan,
List<RecordBatch> children) |
ScanBatch |
HiveScanBatchCreator.getBatch(ExecutorFragmentContext context,
HiveSubScan config,
List<RecordBatch> children) |
Modifier and Type | Method and Description |
---|---|
static List<RecordReader> |
ReadersInitializer.init(ExecutorFragmentContext ctx,
HiveSubScan config)
Selects reader constructor reference as
HiveReaderFactory readerFactory. |
Modifier and Type | Method and Description |
---|---|
CloseableRecordBatch |
HttpScanBatchCreator.getBatch(ExecutorFragmentContext context,
HttpSubScan subScan,
List<RecordBatch> children) |
Modifier and Type | Method and Description |
---|---|
ScanBatch |
InfoSchemaBatchCreator.getBatch(ExecutorFragmentContext context,
InfoSchemaSubScan config,
List<RecordBatch> children) |
Modifier and Type | Method and Description |
---|---|
ScanBatch |
JdbcBatchCreator.getBatch(ExecutorFragmentContext context,
JdbcSubScan config,
List<RecordBatch> children) |
Modifier and Type | Method and Description |
---|---|
CloseableRecordBatch |
KafkaScanBatchCreator.getBatch(ExecutorFragmentContext context,
KafkaSubScan subScan,
List<RecordBatch> children) |
Modifier and Type | Method and Description |
---|---|
ScanBatch |
KuduScanBatchCreator.getBatch(ExecutorFragmentContext context,
KuduSubScan subScan,
List<RecordBatch> children) |
CloseableRecordBatch |
KuduWriterBatchCreator.getBatch(ExecutorFragmentContext context,
KuduWriter config,
List<RecordBatch> children) |
Modifier and Type | Method and Description |
---|---|
ScanBatch |
MapRDBScanBatchCreator.getBatch(ExecutorFragmentContext context,
MapRDBSubScan subScan,
List<RecordBatch> children) |
ScanBatch |
MapRDBRestrictedScanBatchCreator.getBatch(ExecutorFragmentContext context,
RestrictedMapRDBSubScan subScan,
List<RecordBatch> children) |
Modifier and Type | Method and Description |
---|---|
CloseableRecordBatch |
MockScanBatchCreator.getBatch(ExecutorFragmentContext context,
MockSubScanPOP config,
List<RecordBatch> children) |
Modifier and Type | Method and Description |
---|---|
ScanBatch |
MongoScanBatchCreator.getBatch(ExecutorFragmentContext context,
MongoSubScan subScan,
List<RecordBatch> children) |
Modifier and Type | Method and Description |
---|---|
CloseableRecordBatch |
OpenTSDBBatchCreator.getBatch(ExecutorFragmentContext context,
OpenTSDBSubScan subScan,
List<RecordBatch> children) |
Modifier and Type | Method and Description |
---|---|
protected ScanBatch |
AbstractParquetScanBatchCreator.getBatch(ExecutorFragmentContext context,
AbstractParquetRowGroupScan rowGroupScan,
OperatorContext oContext) |
ScanBatch |
ParquetScanBatchCreator.getBatch(ExecutorFragmentContext context,
ParquetRowGroupScan rowGroupScan,
List<RecordBatch> children) |
WriterRecordBatch |
ParquetWriterBatchCreator.getBatch(ExecutorFragmentContext context,
ParquetWriter config,
List<RecordBatch> children) |
Modifier and Type | Method and Description |
---|---|
ScanBatch |
SystemTableBatchCreator.getBatch(ExecutorFragmentContext context,
SystemTableScan scan,
List<RecordBatch> children) |
Iterator<Object> |
SystemTable.getIterator(ExecutorFragmentContext context,
int maxRecords) |
Constructor and Description |
---|
BitToUserConnectionIterator(ExecutorFragmentContext context) |
DrillbitIterator(ExecutorFragmentContext c) |
FunctionsIterator(ExecutorFragmentContext context) |
MemoryIterator(ExecutorFragmentContext context) |
ProfileInfoIterator(ExecutorFragmentContext context,
int maxRecords) |
ProfileIterator(ExecutorFragmentContext context,
int maxRecords) |
ProfileJsonIterator(ExecutorFragmentContext context,
int maxRecords) |
ThreadsIterator(ExecutorFragmentContext context) |
Constructor and Description |
---|
RuntimeFilterReporter(ExecutorFragmentContext context) |
Modifier and Type | Field and Description |
---|---|
protected ExecutorFragmentContext |
FragmentStatusReporter.context |
protected ExecutorFragmentContext |
AbstractFragmentManager.fragmentContext |
Modifier and Type | Method and Description |
---|---|
ExecutorFragmentContext |
FragmentExecutor.getContext() |
Constructor and Description |
---|
FragmentExecutor(ExecutorFragmentContext context,
BitControl.PlanFragment fragment,
FragmentStatusReporter statusReporter)
Create a FragmentExecutor where we need to parse and materialize the root operator.
|
FragmentExecutor(ExecutorFragmentContext context,
BitControl.PlanFragment fragment,
FragmentStatusReporter statusReporter,
FragmentRoot rootOperator)
Create a FragmentExecutor where we already have a root operator in memory.
|
FragmentStatusReporter(ExecutorFragmentContext context) |
Modifier and Type | Class and Description |
---|---|
protected static class |
PhysicalOpUnitTestBase.MockExecutorFragmentContext
Note
|
Copyright © 2021 The Apache Software Foundation. All rights reserved.