Uses of Interface
org.apache.drill.exec.ops.OperatorContext
Package
Description
Defines a revised implementation of the Drill RecordBatch protocol.
Defines the scan operation implementation.
Defines the projection, vector continuity and other operations for
a set of one or more readers.
Provides the "version 3" scan framework (which can also be thought of
as EVF version 2).
Implements the details of the scan lifecycle for a set of readers,
primarily the process of resolving the scan output schema from a variety
of input schemas, then running each reader, each of which will produce
some number of batches.
Defines a mock data source which generates dummy test data for use
in testing.
MongoDB storage plugin.
-
Uses of OperatorContext in org.apache.drill.exec.ops
Modifier and TypeClassDescriptionclass
Implementation ofOperatorContext
that provides services needed by most run-time operators.Modifier and TypeMethodDescriptionFragmentContext.newOperatorContext
(PhysicalOperator popConfig) FragmentContext.newOperatorContext
(PhysicalOperator popConfig, OperatorStats stats) FragmentContextImpl.newOperatorContext
(PhysicalOperator popConfig) FragmentContextImpl.newOperatorContext
(PhysicalOperator popConfig, OperatorStats stats) FragmentContextInterface.newOperatorContext
(PhysicalOperator popConfig) FragmentContextInterface.newOperatorContext
(PhysicalOperator popConfig, OperatorStats stats) -
Uses of OperatorContext in org.apache.drill.exec.physical.impl
ModifierConstructorDescriptionBaseRootExec
(RootFragmentContext fragmentContext, OperatorContext oContext, PhysicalOperator config) Mutator
(OperatorContext oContext, BufferAllocator allocator, VectorContainer container) ScanBatch
(FragmentContext context, OperatorContext oContext, List<? extends RecordReader> readerList, List<Map<String, String>> implicitColumnList) -
Uses of OperatorContext in org.apache.drill.exec.physical.impl.aggregate
Modifier and TypeMethodDescriptionvoid
HashAggregator.setup
(HashAggregate hashAggrConfig, HashTableConfig htConfig, FragmentContext context, OperatorContext oContext, RecordBatch incoming, HashAggBatch outgoing, LogicalExpression[] valueExprs, List<TypedFieldId> valueFieldIds, ClassGenerator<?> cg, TypedFieldId[] keyFieldIds, VectorContainer outContainer, int extraRowBytes) void
HashAggTemplate.setup
(HashAggregate hashAggrConfig, HashTableConfig htConfig, FragmentContext context, OperatorContext oContext, RecordBatch incoming, HashAggBatch outgoing, LogicalExpression[] valueExprs, List<TypedFieldId> valueFieldIds, ClassGenerator<?> cg, TypedFieldId[] groupByOutFieldIds, VectorContainer outContainer, int extraRowBytes) void
StreamingAggregator.setup
(OperatorContext context, RecordBatch incoming, StreamingAggBatch outgoing, int outputRowCount) void
StreamingAggTemplate.setup
(OperatorContext context, RecordBatch incoming, StreamingAggBatch outgoing, int outputRowCount) ModifierConstructorDescriptionInternalBatch
(RecordBatch incoming, OperatorContext oContext) InternalBatch
(RecordBatch incoming, VectorWrapper<?>[] ignoreWrappers, OperatorContext oContext) SpilledRecordBatch
(String spillFile, int spilledBatches, FragmentContext context, BatchSchema schema, OperatorContext oContext, SpillSet spillSet) -
Uses of OperatorContext in org.apache.drill.exec.physical.impl.materialize
ModifierConstructorDescriptionVectorRecordMaterializer
(FragmentContext context, OperatorContext oContext, RecordBatch batch) -
Uses of OperatorContext in org.apache.drill.exec.physical.impl.partitionsender
Modifier and TypeMethodDescriptionvoid
Partitioner.setup
(ExchangeFragmentContext context, RecordBatch incoming, HashPartitionSender popConfig, OperatorStats stats, OperatorContext oContext, ClassGenerator<?> cg, int start, int count) final void
PartitionerTemplate.setup
(ExchangeFragmentContext context, RecordBatch incoming, HashPartitionSender popConfig, OperatorStats stats, OperatorContext oContext, ClassGenerator<?> cg, int start, int end) -
Uses of OperatorContext in org.apache.drill.exec.physical.impl.protocol
Modifier and TypeMethodDescriptionvoid
OperatorExec.bind
(OperatorContext context) Bind this operator to the context.ModifierConstructorDescriptionOperatorDriver
(OperatorContext opContext, OperatorExec opExec, boolean enableSchemaBatch) -
Uses of OperatorContext in org.apache.drill.exec.physical.impl.scan
Modifier and TypeMethodDescriptionvoid
ScanOperatorEvents.bind
(OperatorContext context) Build the scan-level schema from the physical operator select list.void
ScanOperatorExec.bind
(OperatorContext context) -
Uses of OperatorContext in org.apache.drill.exec.physical.impl.scan.framework
-
Uses of OperatorContext in org.apache.drill.exec.physical.impl.scan.v3
-
Uses of OperatorContext in org.apache.drill.exec.physical.impl.scan.v3.file
ModifierConstructorDescriptionFileScanLifecycle
(OperatorContext context, FileScanLifecycleBuilder options) -
Uses of OperatorContext in org.apache.drill.exec.physical.impl.scan.v3.lifecycle
ModifierConstructorDescriptionScanLifecycle
(OperatorContext context, ScanLifecycleBuilder builder) -
Uses of OperatorContext in org.apache.drill.exec.physical.impl.window
Modifier and TypeMethodDescriptionvoid
FrameSupportTemplate.setup
(List<WindowDataBatch> batches, VectorContainer container, OperatorContext oContext, boolean requireFullPartition, WindowPOP popConfig) void
NoFrameSupportTemplate.setup
(List<WindowDataBatch> batches, VectorContainer container, OperatorContext oContext, boolean requireFullPartition, WindowPOP popConfig) void
WindowFramer.setup
(List<WindowDataBatch> batches, VectorContainer container, OperatorContext operatorContext, boolean requireFullPartition, WindowPOP popConfig) -
Uses of OperatorContext in org.apache.drill.exec.physical.impl.xsort
ModifierConstructorDescriptionBaseSortWrapper
(OperatorContext opContext) BaseWrapper
(OperatorContext context) BufferedBatches
(OperatorContext opContext) MergeSortWrapper
(OperatorContext opContext, VectorContainer destContainer) PriorityQueueCopierWrapper
(OperatorContext opContext) SorterWrapper
(OperatorContext opContext) SortImpl
(OperatorContext opContext, SortConfig sortConfig, SpilledRuns spilledRuns, VectorContainer batch) SpilledRuns
(OperatorContext opContext, SpillSet spillSet, PriorityQueueCopierWrapper copier) -
Uses of OperatorContext in org.apache.drill.exec.planner.sql.handlers
Modifier and TypeMethodDescriptionvoid
FindLimit0Visitor.RelDataTypeReader.setup
(OperatorContext context, OutputMutator output) -
Uses of OperatorContext in org.apache.drill.exec.record
Modifier and TypeMethodDescriptionstatic VectorContainer
SchemaUtil.coerceContainer
(VectorAccessible in, BatchSchema toSchema, OperatorContext context) Creates a copy a record batch, converting any fields as necessary to coerce it into the provided schemastatic VectorContainer
VectorContainer.getTransferClone
(VectorAccessible incoming, OperatorContext oContext) Get a set of transferred clones of this container.static VectorContainer
VectorContainer.getTransferClone
(VectorAccessible incoming, VectorWrapper<?>[] ignoreWrappers, OperatorContext oContext) ModifierConstructorDescriptionprotected
AbstractRecordBatch
(T popConfig, FragmentContext context, boolean buildSchema, OperatorContext oContext) RecordIterator
(RecordBatch incoming, AbstractRecordBatch<?> outgoing, OperatorContext oContext, int inputIndex, boolean enableMarkAndReset, RecordBatchMemoryManager callBack) RecordIterator
(RecordBatch incoming, AbstractRecordBatch<?> outgoing, OperatorContext oContext, int inputIndex, RecordBatchMemoryManager callBack) VectorContainer
(OperatorContext oContext) -
Uses of OperatorContext in org.apache.drill.exec.store
Modifier and TypeFieldDescriptionprotected OperatorContext
CommonParquetRecordReader.operatorContext
Modifier and TypeMethodDescriptionvoid
RecordReader.setup
(OperatorContext context, OutputMutator output) Configure the RecordReader with the provided schema and the record batch that should be written to. -
Uses of OperatorContext in org.apache.drill.exec.store.delta.read
Modifier and TypeMethodDescriptionDeltaScanBatchCreator.getDrillFileSystemCreator
(OperatorContext operatorContext, OptionManager optionManager) -
Uses of OperatorContext in org.apache.drill.exec.store.druid
Modifier and TypeMethodDescriptionvoid
DruidRecordReader.setup
(OperatorContext context, OutputMutator output) -
Uses of OperatorContext in org.apache.drill.exec.store.easy.json
Modifier and TypeMethodDescriptionvoid
JSONRecordReader.setup
(OperatorContext context, OutputMutator output) Deprecated. -
Uses of OperatorContext in org.apache.drill.exec.store.googlesheets
ModifierConstructorDescriptionGoogleSheetsBatchInsertWriter
(OperatorContext context, String name, GoogleSheetsWriter config) GoogleSheetsBatchWriter
(OperatorContext context, String name, GoogleSheetsWriter config) -
Uses of OperatorContext in org.apache.drill.exec.store.hbase
Modifier and TypeMethodDescriptionvoid
HBaseRecordReader.setup
(OperatorContext context, OutputMutator output) -
Uses of OperatorContext in org.apache.drill.exec.store.hive
Modifier and TypeMethodDescriptionHiveDrillNativeParquetScanBatchCreator.getDrillFileSystemCreator
(OperatorContext operatorContext, OptionManager optionManager) -
Uses of OperatorContext in org.apache.drill.exec.store.hive.readers
Modifier and TypeMethodDescriptionvoid
HiveDefaultRecordReader.setup
(OperatorContext context, OutputMutator output) -
Uses of OperatorContext in org.apache.drill.exec.store.kudu
Modifier and TypeMethodDescriptionvoid
KuduRecordReader.setup
(OperatorContext context, OutputMutator output) ModifierConstructorDescriptionKuduRecordWriterImpl
(OperatorContext context, org.apache.kudu.client.KuduClient client, String name) -
Uses of OperatorContext in org.apache.drill.exec.store.mock
Modifier and TypeMethodDescriptionvoid
MockRecordReader.setup
(OperatorContext context, OutputMutator output) -
Uses of OperatorContext in org.apache.drill.exec.store.mongo
Modifier and TypeMethodDescriptionvoid
MongoRecordReader.setup
(OperatorContext context, OutputMutator output) -
Uses of OperatorContext in org.apache.drill.exec.store.openTSDB
Modifier and TypeMethodDescriptionvoid
OpenTSDBRecordReader.setup
(OperatorContext context, OutputMutator output) -
Uses of OperatorContext in org.apache.drill.exec.store.parquet
Modifier and TypeFieldDescriptionprotected final OperatorContext
AbstractParquetScanBatchCreator.AbstractDrillFileSystemManager.operatorContext
Modifier and TypeMethodDescriptionprotected ScanBatch
AbstractParquetScanBatchCreator.getBatch
(ExecutorFragmentContext context, AbstractParquetRowGroupScan rowGroupScan, OperatorContext oContext) protected abstract AbstractParquetScanBatchCreator.AbstractDrillFileSystemManager
AbstractParquetScanBatchCreator.getDrillFileSystemCreator
(OperatorContext operatorContext, OptionManager optionManager) ParquetScanBatchCreator.getDrillFileSystemCreator
(OperatorContext operatorContext, OptionManager optionManager) ModifierConstructorDescriptionprotected
AbstractDrillFileSystemManager
(OperatorContext operatorContext) ParquetDrillFileSystemManager
(OperatorContext operatorContext, boolean useAsyncPageReader) -
Uses of OperatorContext in org.apache.drill.exec.store.parquet.columnreaders
Modifier and TypeMethodDescriptionvoid
ParquetRecordReader.setup
(OperatorContext operatorContext, OutputMutator output) Prepare the Parquet reader. -
Uses of OperatorContext in org.apache.drill.exec.store.parquet2
Modifier and TypeMethodDescriptionvoid
DrillParquetReader.setup
(OperatorContext context, OutputMutator output) -
Uses of OperatorContext in org.apache.drill.exec.store.pojo
Modifier and TypeMethodDescriptionvoid
AbstractPojoRecordReader.setup
(OperatorContext context, OutputMutator output) -
Uses of OperatorContext in org.apache.drill.exec.util.record
ModifierConstructorDescriptionRecordBatchStatsContext
(FragmentContext context, OperatorContext oContext)