Uses of Class
org.apache.drill.exec.record.BatchSchema

Packages that use BatchSchema

Package	Description
org.apache.drill.exec.exception	Execution-time exceptions.
org.apache.drill.exec.physical.impl
org.apache.drill.exec.physical.impl.aggregate
org.apache.drill.exec.physical.impl.mergereceiver
org.apache.drill.exec.physical.impl.metadata
org.apache.drill.exec.physical.impl.partitionsender
org.apache.drill.exec.physical.impl.protocol	Defines a revised implementation of the Drill RecordBatch protocol.
org.apache.drill.exec.physical.impl.svremover
org.apache.drill.exec.physical.impl.unnest
org.apache.drill.exec.physical.impl.unorderedreceiver
org.apache.drill.exec.physical.impl.validate
org.apache.drill.exec.physical.impl.window
org.apache.drill.exec.physical.impl.xsort
org.apache.drill.exec.physical.rowSet	Provides a set of tools to work with row sets.
org.apache.drill.exec.physical.unit
org.apache.drill.exec.record
org.apache.drill.exec.store.easy.text.writer
org.apache.drill.jdbc	JDBC driver for Drill.
org.apache.drill.jdbc.impl
org.apache.drill.test	Provides a variety of test framework tools to simplify Drill unit tests and ad-hoc tests created while developing features.
org.apache.drill.test.rowSet	Provides a set of tools to work with row sets when creating operator and "sub-operator" unit tests.

Uses of BatchSchema in org.apache.drill.exec.exception

Methods in org.apache.drill.exec.exception with parameters of type BatchSchema

Modifier and Type	Method and Description
static 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

Modifier and Type	Method and Description
BatchSchema	MockRecordBatch.getSchema()
BatchSchema	ScanBatch.getSchema()
BatchSchema	WriterRecordBatch.getSchema()
BatchSchema	StatisticsWriterRecordBatch.getSchema()

Methods in org.apache.drill.exec.physical.impl with parameters of type BatchSchema

Modifier and Type	Method and Description
MockRecordBatch.Builder	MockRecordBatch.Builder.setSchema(BatchSchema batchSchema)

Constructors in org.apache.drill.exec.physical.impl with parameters of type BatchSchema

Constructor and Description
MockRecordBatch(FragmentContext context, OperatorContext oContext, @NotNull List<VectorContainer> testContainers, @NotNull List<RecordBatch.IterOutcome> iterOutcomes, BatchSchema schema)
MockRecordBatch(FragmentContext context, OperatorContext oContext, @NotNull List<VectorContainer> testContainers, @NotNull List<RecordBatch.IterOutcome> iterOutcomes, @NotNull List<SelectionVector2> selectionVector2s, BatchSchema schema) Deprecated.

Uses of BatchSchema in org.apache.drill.exec.physical.impl.aggregate

Methods in org.apache.drill.exec.physical.impl.aggregate that return BatchSchema

Modifier and Type	Method and Description
BatchSchema	SpilledRecordBatch.getSchema()
BatchSchema	InternalBatch.getSchema()

Constructors in org.apache.drill.exec.physical.impl.aggregate with parameters of type BatchSchema

Constructor and Description
SpilledRecordBatch(String spillFile, int spilledBatches, FragmentContext context, BatchSchema schema, OperatorContext oContext, SpillSet spillSet)

Uses of BatchSchema in org.apache.drill.exec.physical.impl.mergereceiver

Methods in org.apache.drill.exec.physical.impl.mergereceiver that return BatchSchema

Modifier and Type	Method and Description
BatchSchema	MergingRecordBatch.getSchema()

Uses of BatchSchema in org.apache.drill.exec.physical.impl.metadata

Constructors in org.apache.drill.exec.physical.impl.metadata with parameters of type BatchSchema

Constructor and Description
MetadataAggregateHelper(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

Modifier and Type	Method and Description
BatchSchema	PartitionerTemplate.OutgoingRecordBatch.getSchema()

Uses of BatchSchema in org.apache.drill.exec.physical.impl.protocol

Methods in org.apache.drill.exec.physical.impl.protocol that return BatchSchema

Modifier and Type	Method and Description
BatchSchema	OperatorRecordBatch.getSchema()
BatchSchema	BatchAccessor.schema()
BatchSchema	VectorContainerAccessor.schema()
BatchSchema	SchemaTracker.schema()

Uses of BatchSchema in org.apache.drill.exec.physical.impl.svremover

Methods in org.apache.drill.exec.physical.impl.svremover that return BatchSchema

Modifier and Type	Method and Description
protected BatchSchema	AbstractGenericCopierTest.createTestSchema(BatchSchema.SelectionVectorMode mode)

Uses of BatchSchema in org.apache.drill.exec.physical.impl.unnest

Methods in org.apache.drill.exec.physical.impl.unnest that return BatchSchema

Modifier and Type	Method and Description
BatchSchema	MockLateralJoinBatch.getSchema()

Uses of BatchSchema in org.apache.drill.exec.physical.impl.unorderedreceiver

Methods in org.apache.drill.exec.physical.impl.unorderedreceiver that return BatchSchema

Modifier and Type	Method and Description
BatchSchema	UnorderedReceiverBatch.getSchema()

Uses of BatchSchema in org.apache.drill.exec.physical.impl.validate

Methods in org.apache.drill.exec.physical.impl.validate that return BatchSchema

Modifier and Type	Method and Description
BatchSchema	IteratorValidatorBatchIterator.getSchema()

Uses of BatchSchema in org.apache.drill.exec.physical.impl.window

Methods in org.apache.drill.exec.physical.impl.window that return BatchSchema

Modifier and Type	Method and Description
BatchSchema	WindowDataBatch.getSchema()

Uses of BatchSchema in org.apache.drill.exec.physical.impl.xsort

Fields in org.apache.drill.exec.physical.impl.xsort declared as BatchSchema

Modifier and Type	Field and Description
protected BatchSchema	BatchGroup.schema

Methods in org.apache.drill.exec.physical.impl.xsort that return BatchSchema

Modifier and Type	Method and Description
BatchSchema	BatchGroup.getSchema()

Methods in org.apache.drill.exec.physical.impl.xsort with parameters of type BatchSchema

Modifier and Type	Method and Description
void	SpilledRuns.setSchema(BatchSchema schema)
void	SortImpl.setSchema(BatchSchema schema)
void	BatchGroup.setSchema(BatchSchema schema) Updates the schema for this batch group.
void	BufferedBatches.setSchema(BatchSchema schema)
PriorityQueueCopierWrapper.BatchMerger	PriorityQueueCopierWrapper.startMerge(BatchSchema schema, List<? extends BatchGroup> batchGroupList, VectorContainer outputContainer, int targetRecordCount, VectorInitializer allocHelper) Start a merge operation using the specified vector container.
void	SortImpl.SortResults.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	PriorityQueueCopierWrapper.BatchMerger.updateOutputContainer(VectorContainer container, SelectionVector4 sv4, RecordBatch.IterOutcome outcome, BatchSchema schema)
void	MergeSortWrapper.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 BatchSchema

Modifier and Type	Method and Description
BatchSchema	AbstractRowSet.batchSchema()
BatchSchema	RowSet.batchSchema()

Methods in org.apache.drill.exec.physical.rowSet with parameters of type BatchSchema

Modifier and Type	Method and Description
static DirectRowSet	DirectRowSet.fromSchema(BufferAllocator allocator, BatchSchema schema)

Constructors in org.apache.drill.exec.physical.rowSet with parameters of type BatchSchema

Constructor and Description
RowSetBuilder(BufferAllocator allocator, BatchSchema schema) Deprecated. Use RowSetBuilder.RowSetBuilder(BufferAllocator, TupleMetadata) instead.

Uses of BatchSchema in org.apache.drill.exec.physical.unit

Fields in org.apache.drill.exec.physical.unit declared as BatchSchema

Modifier and Type	Field and Description
protected BatchSchema	MiniPlanUnitTestBase.MiniPlanTestBuilder.expectSchema

Methods in org.apache.drill.exec.physical.unit with parameters of type BatchSchema

Modifier and Type	Method and Description
MiniPlanUnitTestBase.MiniPlanTestBuilder	MiniPlanUnitTestBase.MiniPlanTestBuilder.expectSchema(BatchSchema batchSchema) Specify the expected batch schema.

Uses of BatchSchema in org.apache.drill.exec.record

Methods in org.apache.drill.exec.record that return BatchSchema

Modifier and Type	Method and Description
BatchSchema	BatchSchemaBuilder.build()
BatchSchema	SchemaBuilder.build() Generate a new BatchSchema object based on the current state of the builder.
BatchSchema	BatchSchema.clone()
BatchSchema	SchemalessBatch.getSchema()
BatchSchema	RecordIterator.getSchema()
BatchSchema	VectorContainer.getSchema()
BatchSchema	VectorAccessible.getSchema() Get the schema of the current RecordBatch.
BatchSchema	RecordBatch.getSchema() Gets the current schema of this record batch.
BatchSchema	SimpleRecordBatch.getSchema()
BatchSchema	RecordBatchLoader.getSchema()
BatchSchema	AbstractRecordBatch.getSchema()
BatchSchema	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 BatchSchema

Modifier and Type	Method and Description
void	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 schema
static 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 in MaterializedField.isEquivalent(MaterializedField).
BatchSchema	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 BatchSchema

Constructor and Description
BatchSchemaBuilder(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.easy.text.writer

Methods in org.apache.drill.exec.store.easy.text.writer with parameters of type BatchSchema

Modifier and Type	Method and Description
void	TextRecordWriter.startNewSchema(BatchSchema schema)

Uses of BatchSchema in org.apache.drill.jdbc

Methods in org.apache.drill.jdbc with parameters of type BatchSchema

Modifier and Type	Method and Description
void	SchemaChangeListener.schemaChanged(BatchSchema newSchema)

Uses of BatchSchema in org.apache.drill.jdbc.impl

Methods in org.apache.drill.jdbc.impl with parameters of type BatchSchema

Modifier and Type	Method and Description
void	DrillColumnMetaDataList.updateColumnMetaData(String catalogName, String schemaName, String tableName, BatchSchema schema, List<Class<?>> getObjectClasses)

Uses of BatchSchema in org.apache.drill.test

Methods in org.apache.drill.test with parameters of type BatchSchema

Modifier and Type	Method and Description
static int	DrillTestWrapper.addToCombinedVectorResults(Iterable<VectorAccessible> batches, BatchSchema expectedSchema, Long expectedBatchSize, Integer expectedNumBatches, Map<String,List<Object>> combinedVectors, Integer expectedTotalRecords) Add to result vectors and compare batch schema against expected schema while iterating batches.
void	DrillTestWrapper.checkColumnDef(BatchSchema batchSchema)
RowSet.ExtendableRowSet	OperatorFixture.rowSet(BatchSchema schema)
RowSetBuilder	OperatorFixture.rowSetBuilder(BatchSchema schema)
RowSetBuilder	ClientFixture.rowSetBuilder(BatchSchema schema)
TestBuilder.SchemaTestBuilder	TestBuilder.schemaBaseLine(BatchSchema batchSchema)

Uses of BatchSchema in org.apache.drill.test.rowSet

Methods in org.apache.drill.test.rowSet with parameters of type BatchSchema

Modifier and Type	Method and Description
static void	RowSetUtilities.assertSchemasEqual(TupleMetadata expected, BatchSchema actual)