Uses of Class
org.apache.drill.exec.record.BatchSchema
Package
Description
Execution-time exceptions.
Defines a revised implementation of the Drill RecordBatch protocol.
Provides a set of tools to work with row sets.
Drill storage plugin.
JDBC driver for Drill.
-
Uses of BatchSchema in org.apache.drill.exec.exception
Modifier and TypeMethodDescriptionstatic SchemaChangeException
SchemaChangeException.schemaChanged
(String message, BatchSchema priorSchema, BatchSchema newSchema) -
Uses of BatchSchema in org.apache.drill.exec.physical.impl
-
Uses of BatchSchema in org.apache.drill.exec.physical.impl.aggregate
ModifierConstructorDescriptionSpilledRecordBatch
(String spillFile, int spilledBatches, FragmentContext context, BatchSchema schema, OperatorContext oContext, SpillSet spillSet) -
Uses of BatchSchema in org.apache.drill.exec.physical.impl.join
Modifier and TypeFieldDescriptionprotected BatchSchema
AbstractHashBinaryRecordBatch.buildSchema
protected BatchSchema
AbstractHashBinaryRecordBatch.probeSchema
protected BatchSchema
ProbeTemplate.probeSchema
-
Uses of BatchSchema in org.apache.drill.exec.physical.impl.mergereceiver
-
Uses of BatchSchema in org.apache.drill.exec.physical.impl.metadata
ModifierConstructorDescriptionMetadataAggregateHelper
(MetadataAggregateContext context, ColumnNamesOptions columnNamesOptions, BatchSchema schema, AggPrelBase.OperatorPhase phase) -
Uses of BatchSchema in org.apache.drill.exec.physical.impl.partitionsender
-
Uses of BatchSchema in org.apache.drill.exec.physical.impl.protocol
-
Uses of BatchSchema in org.apache.drill.exec.physical.impl.unorderedreceiver
-
Uses of BatchSchema in org.apache.drill.exec.physical.impl.validate
-
Uses of BatchSchema in org.apache.drill.exec.physical.impl.window
-
Uses of BatchSchema in org.apache.drill.exec.physical.impl.xsort
Modifier and TypeMethodDescriptionvoid
BatchGroup.setSchema
(BatchSchema schema) Updates the schema for this batch group.void
BufferedBatches.setSchema
(BatchSchema schema) void
SortImpl.setSchema
(BatchSchema schema) void
SpilledRuns.setSchema
(BatchSchema schema) PriorityQueueCopierWrapper.startMerge
(BatchSchema schema, List<? extends BatchGroup> batchGroupList, VectorContainer outputContainer, int targetRecordCount, VectorInitializer allocHelper) Start a merge operation using the specified vector container.void
MergeSortWrapper.updateOutputContainer
(VectorContainer container, SelectionVector4 sv4, RecordBatch.IterOutcome outcome, BatchSchema schema) void
PriorityQueueCopierWrapper.BatchMerger.updateOutputContainer
(VectorContainer container, SelectionVector4 sv4, RecordBatch.IterOutcome outcome, BatchSchema schema) void
SortImpl.EmptyResults.updateOutputContainer
(VectorContainer container, SelectionVector4 sv4, RecordBatch.IterOutcome outcome, BatchSchema schema) void
SortImpl.SingleBatchResults.updateOutputContainer
(VectorContainer container, SelectionVector4 sv4, RecordBatch.IterOutcome outcome, BatchSchema schema) void
SortImpl.SortResults.updateOutputContainer
(VectorContainer container, SelectionVector4 sv4, RecordBatch.IterOutcome outcome, BatchSchema schema) -
Uses of BatchSchema in org.apache.drill.exec.physical.rowSet
Modifier and TypeMethodDescriptionstatic DirectRowSet
DirectRowSet.fromSchema
(BufferAllocator allocator, BatchSchema schema) ModifierConstructorDescriptionRowSetBuilder
(BufferAllocator allocator, BatchSchema schema) Deprecated. -
Uses of BatchSchema in org.apache.drill.exec.record
Modifier and TypeMethodDescriptionBatchSchemaBuilder.build()
SchemaBuilder.build()
Generate a new BatchSchema object based on the current state of the builder.BatchSchema.clone()
AbstractRecordBatch.getSchema()
RecordBatch.getSchema()
Gets the current schema of this record batch.RecordBatchLoader.getSchema()
RecordIterator.getSchema()
SchemalessBatch.getSchema()
SimpleRecordBatch.getSchema()
VectorAccessible.getSchema()
Get the schema of the current RecordBatch.VectorContainer.getSchema()
BatchSchema.merge
(BatchSchema otherSchema) Merge two schemas to produce a new, merged schema.static BatchSchema
SchemaUtil.mergeSchemas
(BatchSchema... schemas) Returns the merger of schemas.Modifier and TypeMethodDescriptionvoid
VectorContainer.buildFrom
(BatchSchema sourceSchema) static VectorContainer
SchemaUtil.coerceContainer
(VectorAccessible in, BatchSchema toSchema, BufferAllocator allocator) static 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 TupleMetadata
SchemaUtil.fromBatchSchema
(BatchSchema batchSchema) static FragmentWritableBatch
FragmentWritableBatch.getEmptyBatchWithSchema
(boolean isLast, UserBitShared.QueryId queryId, int sendMajorFragmentId, int sendMinorFragmentId, int receiveMajorFragmentId, int receiveMinorFragmentId, BatchSchema schema) static FragmentWritableBatch
FragmentWritableBatch.getEmptyLastWithSchema
(UserBitShared.QueryId queryId, int sendMajorFragmentId, int sendMinorFragmentId, int receiveMajorFragmentId, int receiveMinorFragmentId, BatchSchema schema) boolean
BatchSchema.isEquivalent
(BatchSchema other) Compare that two schemas are identical according to the rules defined inMaterializedField.isEquivalent(MaterializedField)
.BatchSchema.merge
(BatchSchema otherSchema) Merge two schemas to produce a new, merged schema.static BatchSchema
SchemaUtil.mergeSchemas
(BatchSchema... schemas) Returns the merger of schemas.ModifierConstructorDescriptionBatchSchemaBuilder
(BatchSchema baseSchema) Create a new schema starting with the base schema.VectorContainer
(BufferAllocator allocator, BatchSchema schema) Create a new vector container given a pre-defined schema. -
Uses of BatchSchema in org.apache.drill.exec.store
Modifier and TypeMethodDescriptionabstract void
StringOutputRecordWriter.startNewSchema
(BatchSchema schema) -
Uses of BatchSchema in org.apache.drill.exec.store.drill.plugin
-
Uses of BatchSchema in org.apache.drill.exec.store.easy.text.writer
-
Uses of BatchSchema in org.apache.drill.jdbc
-
Uses of BatchSchema in org.apache.drill.jdbc.impl
Modifier and TypeMethodDescriptionvoid
DrillColumnMetaDataList.updateColumnMetaData
(String catalogName, String schemaName, String tableName, BatchSchema schema, List<Class<?>> getObjectClasses)
RowSetBuilder(BufferAllocator, TupleMetadata)
instead.