Uses of Class
org.apache.drill.exec.record.BatchSchema
Packages that use 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
Methods in org.apache.drill.exec.exception with parameters of type BatchSchemaModifier and TypeMethodDescriptionstatic SchemaChangeException
SchemaChangeException.schemaChanged
(String message, BatchSchema priorSchema, BatchSchema newSchema) -
Uses of BatchSchema in org.apache.drill.exec.physical.impl
Methods in org.apache.drill.exec.physical.impl that return BatchSchema -
Uses of BatchSchema in org.apache.drill.exec.physical.impl.aggregate
Methods in org.apache.drill.exec.physical.impl.aggregate that return BatchSchemaConstructors in org.apache.drill.exec.physical.impl.aggregate with parameters of type BatchSchemaModifierConstructorDescriptionSpilledRecordBatch
(String spillFile, int spilledBatches, FragmentContext context, BatchSchema schema, OperatorContext oContext, SpillSet spillSet) -
Uses of BatchSchema in org.apache.drill.exec.physical.impl.join
Fields in org.apache.drill.exec.physical.impl.join declared as BatchSchemaModifier and TypeFieldDescriptionprotected BatchSchema
AbstractHashBinaryRecordBatch.buildSchema
protected BatchSchema
AbstractHashBinaryRecordBatch.probeSchema
protected BatchSchema
ProbeTemplate.probeSchema
-
Uses of BatchSchema in org.apache.drill.exec.physical.impl.mergereceiver
Methods in org.apache.drill.exec.physical.impl.mergereceiver that return BatchSchema -
Uses of BatchSchema in org.apache.drill.exec.physical.impl.metadata
Constructors in org.apache.drill.exec.physical.impl.metadata with parameters of type BatchSchemaModifierConstructorDescriptionMetadataAggregateHelper
(MetadataAggregateContext context, ColumnNamesOptions columnNamesOptions, BatchSchema schema, AggPrelBase.OperatorPhase phase) -
Uses of BatchSchema in org.apache.drill.exec.physical.impl.partitionsender
Methods in org.apache.drill.exec.physical.impl.partitionsender that return BatchSchema -
Uses of BatchSchema in org.apache.drill.exec.physical.impl.protocol
Methods in org.apache.drill.exec.physical.impl.protocol that return BatchSchema -
Uses of BatchSchema in org.apache.drill.exec.physical.impl.unorderedreceiver
Methods in org.apache.drill.exec.physical.impl.unorderedreceiver that return BatchSchema -
Uses of BatchSchema in org.apache.drill.exec.physical.impl.validate
Methods in org.apache.drill.exec.physical.impl.validate that return BatchSchema -
Uses of BatchSchema in org.apache.drill.exec.physical.impl.window
Methods in org.apache.drill.exec.physical.impl.window that return BatchSchema -
Uses of BatchSchema in org.apache.drill.exec.physical.impl.xsort
Fields in org.apache.drill.exec.physical.impl.xsort declared as BatchSchemaMethods in org.apache.drill.exec.physical.impl.xsort that return BatchSchemaMethods in org.apache.drill.exec.physical.impl.xsort with parameters of type BatchSchemaModifier 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
Methods in org.apache.drill.exec.physical.rowSet that return BatchSchemaMethods in org.apache.drill.exec.physical.rowSet with parameters of type BatchSchemaModifier and TypeMethodDescriptionstatic DirectRowSet
DirectRowSet.fromSchema
(BufferAllocator allocator, BatchSchema schema) Constructors in org.apache.drill.exec.physical.rowSet with parameters of type BatchSchemaModifierConstructorDescriptionRowSetBuilder
(BufferAllocator allocator, BatchSchema schema) Deprecated. -
Uses of BatchSchema in org.apache.drill.exec.record
Methods in org.apache.drill.exec.record that return BatchSchemaModifier 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.Methods in org.apache.drill.exec.record with parameters of type BatchSchemaModifier 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.Constructors in org.apache.drill.exec.record with parameters of type BatchSchemaModifierConstructorDescriptionBatchSchemaBuilder
(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
Methods in org.apache.drill.exec.store with parameters of type BatchSchemaModifier and TypeMethodDescriptionabstract void
StringOutputRecordWriter.startNewSchema
(BatchSchema schema) -
Uses of BatchSchema in org.apache.drill.exec.store.drill.plugin
Methods in org.apache.drill.exec.store.drill.plugin that return BatchSchema -
Uses of BatchSchema in org.apache.drill.exec.store.easy.text.writer
Methods in org.apache.drill.exec.store.easy.text.writer with parameters of type BatchSchema -
Uses of BatchSchema in org.apache.drill.jdbc
Methods in org.apache.drill.jdbc with parameters of type BatchSchema -
Uses of BatchSchema in org.apache.drill.jdbc.impl
Methods in org.apache.drill.jdbc.impl with parameters of type BatchSchemaModifier and TypeMethodDescriptionvoid
DrillColumnMetaDataList.updateColumnMetaData
(String catalogName, String schemaName, String tableName, BatchSchema schema, List<Class<?>> getObjectClasses)
RowSetBuilder(BufferAllocator, TupleMetadata)
instead.