Uses of Interface
org.apache.drill.exec.record.metadata.ColumnMetadata
Package
Description
Standard type conversion tools for the case in which the input
types are the standard Java types already supported by the
ValuesWriter
interface.Provides run-time semantic analysis of the projection list for the
scan operator.
Provides run-time semantic analysis of the projection list for the
scan operator.
Handles the details of the result set loader implementation.
The "row set model" provides a "dual" of the vector structure used to create,
allocate and work with a collection of vectors.
Implementation of a row set model for hyper-batches.
Provides a set of tools to work with row sets.
Provides a fluent schema builder.
Provides parsing for Mongo extended types which are generally of the form
{ "$type": value }
.Provides a light-weight, simplified set of column readers and writers that
can be plugged into a variety of row-level readers and writers.
Provides the reader hierarchy as explained in the API package.
Implementation of the vector writers.
This package provides a "dummy" set of writers.
-
Uses of ColumnMetadata in org.apache.drill.exec.physical.impl.scan.convert
Modifier and TypeMethodDescriptionStandardConversions.analyze
(TypeProtos.MinorType inputType, ColumnMetadata outputSchema) StandardConversions.analyze
(ColumnMetadata inputSchema, ColumnMetadata outputSchema) Create converters for standard cases.StandardConversions.converterFor
(ScalarWriter scalarWriter, ColumnMetadata inputSchema) Class<? extends DirectConverter>
StandardConversions.convertFromVarchar
(ColumnMetadata outputDefn) -
Uses of ColumnMetadata in org.apache.drill.exec.physical.impl.scan.project
Modifier and TypeMethodDescriptionAbstractUnresolvedColumn.UnresolvedColumn.metadata()
NullColumnLoader.NullColumnSpec.metadata()
ResolvedColumn.metadata()
ModifierConstructorDescriptionResolvedColumn
(ColumnMetadata outputCol, VectorSource source, int sourceIndex) ResolvedNullColumn
(ColumnMetadata colDefn, VectorSource source, int sourceIndex) ResolvedTableColumn
(ColumnMetadata outputCol, VectorSource source, int sourceIndex) UnresolvedColumn
(RequestedColumn inCol, ColumnMetadata colDefn) -
Uses of ColumnMetadata in org.apache.drill.exec.physical.impl.scan.v3.schema
Modifier and TypeClassDescriptionclass
Enhanced form of a dynamic column which records all information from the project list.Modifier and TypeMethodDescriptionMutableTupleSchema.ColumnHandle.column()
ProjectedColumn.copy()
static ColumnMetadata
SchemaUtils.getColumnMetadata
(String name, org.apache.calcite.rel.type.RelDataType relDataType) Converts specifiedRelDataType relDataType
intoColumnMetadata
.Modifier and TypeMethodDescriptionvoid
MutableTupleSchema.add
(ColumnMetadata col) DynamicSchemaFilter.buildProjection
(ColumnMetadata schemaCol, ColumnMetadata probeCol) static void
SchemaUtils.copyMapProperties
(ProjectedColumn source, ColumnMetadata dest) void
ProjectionSchemaTracker.expandImplicitCol
(ColumnMetadata resolved, ImplicitColumnMarker marker) void
ScanSchemaTracker.expandImplicitCol
(ColumnMetadata resolved, ImplicitColumnMarker marker) Drill defines a wildcard to expand not just reader columns, but also partition columns.void
SchemaBasedTracker.expandImplicitCol
(ColumnMetadata resolved, ImplicitColumnMarker marker) protected ProjectionFilter.ProjResult
DynamicSchemaFilter.fromSchema
(ColumnMetadata schemaCol, ColumnMetadata probeCol) A column exists in the scan schema, and is concrete.static String
SchemaUtils.implicitColType
(ColumnMetadata col) MutableTupleSchema.insert
(int posn, ColumnMetadata col) MutableTupleSchema.insert
(ColumnMetadata col) static boolean
SchemaUtils.isConsistent
(ProjectedColumn colReq, ColumnMetadata readCol) Check if the given read column is consistent with the projection requested for that column.static boolean
SchemaUtils.isExcludedFromWildcard
(ColumnMetadata col) static boolean
SchemaUtils.isImplicit
(ColumnMetadata col) static void
SchemaUtils.markAsPartition
(ColumnMetadata col, int level) static void
SchemaUtils.markExcludeFromWildcard
(ColumnMetadata col) static void
SchemaUtils.markImplicit
(ColumnMetadata col, String value) static void
SchemaUtils.markProjectAll
(ColumnMetadata col) static void
SchemaUtils.mergeColProperties
(ColumnMetadata existing, ColumnMetadata revised) DynamicSchemaFilter.DynamicTupleFilter.projection
(ColumnMetadata col) DynamicSchemaFilter.RowSchemaFilter.projection
(ColumnMetadata col) void
MutableTupleSchema.replace
(MutableTupleSchema.ColumnHandle col, ColumnMetadata resolved) void
MutableTupleSchema.resolve
(MutableTupleSchema.ColumnHandle col, ColumnMetadata resolved) void
MutableTupleSchema.resolveImplicit
(MutableTupleSchema.ColumnHandle col, ColumnMetadata resolved, ImplicitColumnMarker marker) static void
SchemaUtils.verifyCompatibility
(ProjectedColumn colReq, ColumnMetadata actual, String source, CustomErrorContext errorContext) Perform the column-level projection as described inSchemaUtils.isConsistent(ProjectedColumn, ColumnMetadata)
, and raise aUserException
if the column is not consistent with projection.static void
SchemaUtils.verifyConsistency
(ColumnMetadata existing, ColumnMetadata revised, String source, CustomErrorContext errorContext) static void
SchemaUtils.verifyProjection
(ColumnMetadata existing, ColumnMetadata revised, String source, CustomErrorContext errorContext) -
Uses of ColumnMetadata in org.apache.drill.exec.physical.resultSet.impl
Modifier and TypeFieldDescriptionprotected final ColumnMetadata
TupleState.DictColumnState.outputSchema
protected final ColumnMetadata
TupleState.MapColumnState.outputSchema
final ColumnMetadata
ProjectionFilter.ProjResult.projection
Modifier and TypeMethodDescriptionabstract ColumnMetadata
ColumnState.outputSchema()
ColumnState.PrimitiveColumnState.outputSchema()
Get the output schema.RepeatedListState.RepeatedListColumnState.outputSchema()
Get the output schema.TupleState.DictColumnState.outputSchema()
TupleState.MapColumnState.outputSchema()
UnionState.UnionColumnState.outputSchema()
Get the output schema.ColumnState.schema()
RowSetLoaderImpl.schema()
Modifier and TypeMethodDescriptionContainerState.addColumn
(ColumnMetadata columnSchema) TupleState.addColumn
(TupleWriter tupleWriter, ColumnMetadata columnSchema) ListState.addMember
(ColumnMetadata member) UnionState.addMember
(ColumnMetadata member) abstract int
TupleState.addOutputColumn
(ValueVector vector, ColumnMetadata colSchema) int
TupleState.DictArrayState.addOutputColumn
(ValueVector vector, ColumnMetadata colSchema) int
TupleState.MapState.addOutputColumn
(ValueVector vector, ColumnMetadata colSchema) int
TupleState.RowState.addOutputColumn
(ValueVector vector, ColumnMetadata colSchema) BuildFromSchema.buildColumn
(TupleState state, ColumnMetadata colSchema) Build a column recursively.ColumnBuilder.buildColumn
(ContainerState parent, ColumnMetadata columnSchema) Implementation of the work to add a new column to this tuple given a schema description of the column.ProjectionFilter.CompoundProjectionFilter.projection
(ColumnMetadata col) ProjectionFilter.DirectProjectionFilter.projection
(ColumnMetadata col) ProjectionFilter.ImplicitProjectionFilter.projection
(ColumnMetadata col) ProjectionFilter.projection
(ColumnMetadata columnSchema) ProjectionFilter.SchemaProjectionFilter.projection
(ColumnMetadata col) ProjectionFilter.TypeProjectionFilter.projection
(ColumnMetadata col) RepeatedListState.setChild
(ArrayWriter array, ColumnMetadata columnSchema) protected void
ProjectionFilter.BaseSchemaProjectionFilter.validateColumn
(ColumnMetadata schemaCol, ColumnMetadata readerCol) protected void
ProjectionFilter.BaseSchemaProjectionFilter.validateMap
(ColumnMetadata schemaCol) SingleVectorState.vectorState
(ColumnMetadata schema, WriterEvents writer, ValueVector mainVector) ModifierConstructorDescriptionProjResult
(boolean isProjected, ColumnMetadata projection) ProjResult
(boolean isProjected, ColumnMetadata projection, ProjectionFilter mapFilter) VariableWidthVectorState
(ColumnMetadata schema, WriterEvents writer, ValueVector mainVector) -
Uses of ColumnMetadata in org.apache.drill.exec.physical.resultSet.model
Modifier and TypeFieldDescriptionfinal ColumnMetadata
MetadataProvider.VectorDescrip.metadata
protected final ColumnMetadata
BaseTupleModel.BaseColumnModel.schema
Extended schema associated with a column.Modifier and TypeMethodDescriptionMetadataProvider.ArraySchemaCreator.metadata
(int index, MaterializedField field) MetadataProvider.ArraySchemaRetrieval.metadata
(int index, MaterializedField field) MetadataProvider.metadata
(int index, MaterializedField field) MetadataProvider.MetadataCreator.metadata
(int index, MaterializedField field) MetadataProvider.MetadataRetrieval.metadata
(int index, MaterializedField field) MetadataProvider.VariantSchemaCreator.metadata
(int index, MaterializedField field) MetadataProvider.VariantSchemaRetrieval.metadata
(int index, MaterializedField field) BaseTupleModel.BaseColumnModel.schema()
TupleModel.ColumnModel.schema()
Modifier and TypeMethodDescriptionprotected AbstractObjectReader
ReaderBuilder.buildScalarReader
(VectorAccessor va, ColumnMetadata schema) MetadataProvider.ArraySchemaCreator.childProvider
(ColumnMetadata colMetadata) MetadataProvider.ArraySchemaRetrieval.childProvider
(ColumnMetadata colMetadata) MetadataProvider.childProvider
(ColumnMetadata colMetadata) MetadataProvider.MetadataCreator.childProvider
(ColumnMetadata colMetadata) MetadataProvider.MetadataRetrieval.childProvider
(ColumnMetadata colMetadata) MetadataProvider.VariantSchemaCreator.childProvider
(ColumnMetadata colMetadata) MetadataProvider.VariantSchemaRetrieval.childProvider
(ColumnMetadata colMetadata) static MetadataProvider
MetadataProvider.MetadataCreator.makeProvider
(ColumnMetadata colMetadata) static MetadataProvider
MetadataProvider.MetadataRetrieval.makeProvider
(ColumnMetadata colMetadata) ModifierConstructorDescriptionArraySchemaRetrieval
(ColumnMetadata arraySchema) BaseColumnModel
(ColumnMetadata schema) VectorDescrip
(MetadataProvider provider, ColumnMetadata metadata) -
Uses of ColumnMetadata in org.apache.drill.exec.physical.resultSet.model.hyper
Modifier and TypeMethodDescriptionprotected AbstractObjectReader
HyperReaderBuilder.buildVectorReader
(VectorAccessor va, ColumnMetadata metadata) -
Uses of ColumnMetadata in org.apache.drill.exec.physical.resultSet.project
Modifier and TypeMethodDescriptionboolean
ImpliedTupleRequest.enforceProjection
(ColumnMetadata columnSchema, CustomErrorContext errorContext) boolean
RequestedTuple.enforceProjection
(ColumnMetadata columnSchema, CustomErrorContext errorContext) boolean
RequestedTupleImpl.enforceProjection
(ColumnMetadata columnSchema, CustomErrorContext errorContext) static boolean
Projections.excludeFromWildcard
(ColumnMetadata col) Reports whether the column is a special column which should not be expanded in a wildcard.static boolean
ProjectionChecker.isConsistent
(RequestedColumn colReq, ColumnMetadata readCol) Check if the given read column is consistent with the projection requested for that column.static boolean
ProjectionChecker.isConsistent
(RequestedTuple tuple, ColumnMetadata readCol) Check if the given read column is consistent with the projection requested for a tuple.boolean
ImpliedTupleRequest.isProjected
(ColumnMetadata columnSchema) boolean
RequestedTuple.isProjected
(ColumnMetadata columnSchema) boolean
RequestedTupleImpl.isProjected
(ColumnMetadata columnSchema) static void
ProjectionChecker.validateProjection
(RequestedColumn colReq, ColumnMetadata readCol) static void
ProjectionChecker.validateProjection
(RequestedColumn colReq, ColumnMetadata readCol, CustomErrorContext errorContext) Perform the column-level projection as described inProjectionChecker.isConsistent(RequestedColumn, ColumnMetadata)
, and raise aUserException
if the column is not consistent with projection. -
Uses of ColumnMetadata in org.apache.drill.exec.physical.rowSet
-
Uses of ColumnMetadata in org.apache.drill.exec.record
Modifier and TypeMethodDescriptionColumnConverterFactory.buildScalar
(ColumnMetadata readerSchema, ValueWriter writer) ColumnConverterFactory.getConverter
(TupleMetadata providedSchema, ColumnMetadata readerSchema, ObjectWriter writer) Based on column type, creates corresponding column converter which holds conversion logic and appropriate writer to set converted data into. -
Uses of ColumnMetadata in org.apache.drill.exec.record.metadata
Modifier and TypeClassDescriptionclass
Abstract definition of column metadata.class
Describes a base column type for map, dict, repeated map and repeated dict.class
class
A dynamic column has a name but not a type.class
Describes a map and repeated map.class
Primitive (non-map) column.class
class
Modifier and TypeMethodDescriptionTupleMetadata.add
(MaterializedField field) Add a new column to the schema.TupleSchema.add
(MaterializedField field) VariantMetadata.addType
(TypeProtos.MinorType type) Add any supported type to the variant.VariantSchema.addType
(TypeProtos.MinorType type) VariantSchema.addType
(MaterializedField field) TupleSchema.addView
(MaterializedField field) AbstractColumnMetadata.childSchema()
ColumnMetadata.childSchema()
Schema of inner dimension forMULTI_ARRAY
columns.RepeatedListColumnMetadata.childSchema()
ColumnMetadata.cloneEmpty()
Create an empty version of this column.DictColumnMetadata.cloneEmpty()
DynamicColumn.cloneEmpty()
MapColumnMetadata.cloneEmpty()
PrimitiveColumnMetadata.cloneEmpty()
RepeatedListColumnMetadata.cloneEmpty()
VariantColumnMetadata.cloneEmpty()
static ColumnMetadata
MetadataUtils.cloneMapWithSchema
(ColumnMetadata source, TupleMetadata members) ColumnMetadata.copy()
DictColumnMetadata.copy()
DynamicColumn.copy()
MapColumnMetadata.copy()
PrimitiveColumnMetadata.copy()
RepeatedListColumnMetadata.copy()
VariantColumnMetadata.copy()
static ColumnMetadata
MetadataUtils.diffMap
(ColumnMetadata map, ColumnMetadata other) static ColumnMetadata
MetadataUtils.fromField
(MaterializedField field) Create a column metadata object that holds the givenMaterializedField
.static ColumnMetadata
MetadataUtils.fromView
(MaterializedField field) DictColumnMetadata.keyColumnMetadata()
VariantMetadata.listSubtype()
Lists are odd creatures: they contain a union if they have more than one subtype, but are like a nullable repeated type if they contain only one type.VariantSchema.listSubtype()
VariantMetadata.member
(TypeProtos.MinorType type) Retrieve the virtual column for a given type.VariantSchema.member
(TypeProtos.MinorType type) static ColumnMetadata
VariantSchema.memberMetadata
(TypeProtos.MinorType type) PrimitiveColumnMetadata.mergeWith
(MaterializedField field) TupleMetadata.metadata
(int index) TupleSchema.metadata
(int index) static ColumnMetadata
MetadataUtils.newDecimal
(String name, TypeProtos.DataMode mode, int precision, int scale) static ColumnMetadata
MetadataUtils.newDecimal
(String name, TypeProtos.MinorType type, TypeProtos.DataMode mode, int precision, int scale) static ColumnMetadata
MetadataUtils.newDynamic
(String name) static ColumnMetadata
MetadataUtils.newMapArray
(String name) static ColumnMetadata
MetadataUtils.newMapArray
(String name, TupleMetadata schema) TupleMetadata.parent()
VariantMetadata.parent()
Return the column that defines this variant structureVariantSchema.parent()
DictColumnMetadata.valueColumnMetadata()
static ColumnMetadata
MetadataUtils.wildcard()
Modifier and TypeMethodDescriptionTupleSchema.iterator()
VariantMetadata.members()
VariantSchema.members()
TupleMetadata.toMetadataList()
Returns schema as list of ColumnMetadata objects which can be used to create JSON schema object.TupleSchema.toMetadataList()
Modifier and TypeMethodDescriptionSchemaBuilder.add
(ColumnMetadata column) void
TupleSchema.add
(ColumnMetadata md) Add a column metadata column created by the caller.void
DictBuilder.addColumn
(ColumnMetadata column) void
MapBuilder.addColumn
(ColumnMetadata column) void
RepeatedListBuilder.addColumn
(ColumnMetadata column) void
SchemaBuilder.addColumn
(ColumnMetadata column) void
TupleBuilder.addColumn
(ColumnMetadata column) int
TupleMetadata.addColumn
(ColumnMetadata column) int
TupleSchema.addColumn
(ColumnMetadata column) void
UnionBuilder.addColumn
(ColumnMetadata column) void
VariantMetadata.addType
(ColumnMetadata col) Add a column for any supported type to the variant.void
VariantSchema.addType
(ColumnMetadata col) void
RepeatedListColumnMetadata.childSchema
(ColumnMetadata childMetadata) static ColumnMetadata
MetadataUtils.cloneMapWithSchema
(ColumnMetadata source, TupleMetadata members) static ColumnMetadata
MetadataUtils.diffMap
(ColumnMetadata map, ColumnMetadata other) TupleMetadata.fullName
(ColumnMetadata column) Full name of the column.TupleSchema.fullName
(ColumnMetadata column) boolean
AbstractColumnMetadata.isEquivalent
(ColumnMetadata o) boolean
AbstractMapColumnMetadata.isEquivalent
(ColumnMetadata o) boolean
ColumnMetadata.isEquivalent
(ColumnMetadata other) Report whether one column is equivalent to another.boolean
DynamicColumn.isEquivalent
(ColumnMetadata o) boolean
PrimitiveColumnMetadata.isEquivalent
(ColumnMetadata o) boolean
RepeatedListColumnMetadata.isEquivalent
(ColumnMetadata o) boolean
VariantColumnMetadata.isEquivalent
(ColumnMetadata o) static boolean
MetadataUtils.isRepeatedList
(ColumnMetadata col) static boolean
MetadataUtils.isScalar
(ColumnMetadata col) static boolean
MetadataUtils.isWildcard
(ColumnMetadata col) static RepeatedListColumnMetadata
MetadataUtils.newRepeatedList
(String name, ColumnMetadata child) void
TupleMetadata.replace
(ColumnMetadata replaceWith) void
TupleSchema.replace
(ColumnMetadata replaceWith) Modifier and TypeMethodDescriptionstatic TupleSchema
MetadataUtils.fromColumns
(List<ColumnMetadata> columns) Create a tuple given the list of columns that make up the tuple.ModifierConstructorDescriptionRepeatedListColumnMetadata
(String name, ColumnMetadata childSchema) -
Uses of ColumnMetadata in org.apache.drill.exec.record.metadata.schema.parser
Modifier and TypeMethodDescriptionstatic ColumnMetadata
SchemaExprParser.parseColumn
(String column) Parses string definition of the column and converts it intoColumnMetadata
instance.static ColumnMetadata
SchemaExprParser.parseColumn
(String name, String type, TypeProtos.DataMode mode) Parses given column name, type and mode intoColumnMetadata
instance.SchemaVisitor.ColumnDefVisitor.visitColumn_def
(SchemaParser.Column_defContext ctx) SchemaVisitor.ColumnVisitor.visitComplex_array_column
(SchemaParser.Complex_array_columnContext ctx) SchemaVisitor.ColumnVisitor.visitMap_column
(SchemaParser.Map_columnContext ctx) SchemaVisitor.ColumnVisitor.visitPrimitive_column
(SchemaParser.Primitive_columnContext ctx) SchemaVisitor.ColumnVisitor.visitSimple_array_column
(SchemaParser.Simple_array_columnContext ctx) SchemaVisitor.ColumnVisitor.visitStruct_column
(SchemaParser.Struct_columnContext ctx) SchemaVisitor.ColumnVisitor.visitUnion_column
(SchemaParser.Union_columnContext ctx) -
Uses of ColumnMetadata in org.apache.drill.exec.store.avro
Modifier and TypeMethodDescriptionAvroColumnConverterFactory.buildScalar
(ColumnMetadata readerSchema, ValueWriter writer) -
Uses of ColumnMetadata in org.apache.drill.exec.store.cassandra
Modifier and TypeMethodDescriptionCassandraColumnConverterFactory.buildScalar
(ColumnMetadata readerSchema, ValueWriter writer) -
Uses of ColumnMetadata in org.apache.drill.exec.store.easy.json.extended
Modifier and TypeMethodDescriptionExtendedTypeFieldFactory.scalarParserFor
(FieldDefn fieldDefn, ColumnMetadata colSchema) Infer the extended parser from the provided field type. -
Uses of ColumnMetadata in org.apache.drill.exec.store.easy.json.loader
Modifier and TypeMethodDescriptionFieldDefn.providedColumn()
protected ColumnMetadata
BaseFieldFactory.repeatedListSchemaFor
(String key, int dims, ColumnMetadata innerArray) Build up a repeated list column definition given a specification of the number of dimensions and the JSON type.FieldDefn.schemaFor
(TypeProtos.MinorType type, boolean isArray) FieldDefn.schemaFor
(TypeProtos.MinorType type, boolean isArray, boolean forUnknownSchema) Modifier and TypeMethodDescriptionJsonLoaderImpl.buildError
(ColumnMetadata schema, UserException.Builder builder) JsonLoaderImpl.dataConversionError
(ColumnMetadata schema, String tokenType, String value) FieldDefn.fieldWriterFor
(ColumnMetadata colSchema) JsonLoaderImpl.nullDisallowedError
(ColumnMetadata schema) protected ElementParser
BaseFieldFactory.objectArrayParserFor
(FieldDefn fieldDefn, ColumnMetadata colSchema, TupleMetadata providedSchema) Create a map array column and its associated parsers and listeners for the given column schema and optional provided schema.protected ElementParser
BaseFieldFactory.objectParserFor
(FieldDefn fieldDefn, ColumnMetadata colSchema, TupleMetadata providedSchema) Create a map column and its associated object value listener for the given key and optional provided schema.protected ColumnMetadata
BaseFieldFactory.repeatedListSchemaFor
(String key, int dims, ColumnMetadata innerArray) Build up a repeated list column definition given a specification of the number of dimensions and the JSON type.BaseFieldFactory.scalarParserFor
(FieldDefn fieldDefn, ColumnMetadata colSchema) FieldFactory.scalarParserFor
(FieldDefn fieldDefn, ColumnMetadata colSchema) Internal method which allows a custom parser (such as for extended types) to provide the scalar parser for a provided schema.FieldDefn.scalarWriterFor
(ColumnMetadata colSchema) JsonLoaderImpl.typeConversionError
(ColumnMetadata schema, String tokenType) JsonLoaderImpl.typeConversionError
(ColumnMetadata schema, ValueDef valueDef) JsonLoaderImpl.unsupportedType
(ColumnMetadata schema) -
Uses of ColumnMetadata in org.apache.drill.exec.store.easy.json.values
-
Uses of ColumnMetadata in org.apache.drill.exec.store.elasticsearch
Modifier and TypeMethodDescriptionElasticsearchColumnConverterFactory.buildScalar
(ColumnMetadata readerSchema, ValueWriter writer) -
Uses of ColumnMetadata in org.apache.drill.exec.store.hive
Modifier and TypeMethodDescriptionstatic ColumnMetadata
HiveUtilities.getColumnMetadata
(HiveToRelDataTypeConverter dataTypeConverter, org.apache.hadoop.hive.metastore.api.FieldSchema column) Converts specifiedFieldSchema column
intoColumnMetadata
. -
Uses of ColumnMetadata in org.apache.drill.exec.store.iceberg.read
Modifier and TypeMethodDescriptionstatic ColumnMetadata
IcebergColumnConverterFactory.getColumnMetadata
(org.apache.iceberg.types.Types.NestedField field) Modifier and TypeMethodDescriptionIcebergColumnConverterFactory.buildScalar
(ColumnMetadata readerSchema, ValueWriter writer) -
Uses of ColumnMetadata in org.apache.drill.exec.store.ischema
ModifierConstructorDescriptionColumn
(String catalog, String schemaName, String tableName, String columnName, ColumnMetadata columnMetadata, ColumnStatistics<?> columnStatistics, int index, boolean isNested) -
Uses of ColumnMetadata in org.apache.drill.exec.vector.accessor
Modifier and TypeMethodDescriptionColumnReader.schema()
ColumnWriter.schema()
Returns the schema of the column associated with this writer.Modifier and TypeMethodDescriptionint
TupleWriter.addColumn
(ColumnMetadata column) Add a column to the tuple (row or map) that backs this writer.VariantWriter.addMember
(ColumnMetadata schema) VariantWriter.VariantWriterListener.addMember
(ColumnMetadata schema) void
ColumnAccessors.Decimal18ColumnReader.bindVector
(ColumnMetadata schema, VectorAccessor va) void
ColumnAccessors.Decimal28SparseColumnReader.bindVector
(ColumnMetadata schema, VectorAccessor va) void
ColumnAccessors.Decimal38SparseColumnReader.bindVector
(ColumnMetadata schema, VectorAccessor va) void
ColumnAccessors.Decimal9ColumnReader.bindVector
(ColumnMetadata schema, VectorAccessor va) void
ColumnAccessors.VarDecimalColumnReader.bindVector
(ColumnMetadata schema, VectorAccessor va) static UnsupportedConversionError
UnsupportedConversionError.nullError
(ColumnMetadata schema) static UnsupportedConversionError
UnsupportedConversionError.readError
(ColumnMetadata schema, String javaType) static InvalidConversionError
InvalidConversionError.writeError
(ColumnMetadata schema, Object value) static InvalidConversionError
InvalidConversionError.writeError
(ColumnMetadata schema, Object value, Exception e) static UnsupportedConversionError
UnsupportedConversionError.writeError
(ColumnMetadata schema, String javaType) -
Uses of ColumnMetadata in org.apache.drill.exec.vector.accessor.reader
Modifier and TypeFieldDescriptionprotected final ColumnMetadata
AbstractScalarReader.NullReader.schema
protected ColumnMetadata
BaseScalarReader.schema
protected final ColumnMetadata
MapReader.schema
Modifier and TypeMethodDescriptionAbstractObjectReader.schema()
AbstractScalarReader.NullReader.schema()
ArrayReaderImpl.schema()
BaseScalarReader.schema()
DictEntryReader.schema()
MapReader.schema()
OffsetVectorReader.schema()
UnionReaderImpl.schema()
Modifier and TypeMethodDescriptionvoid
BaseScalarReader.BaseVarWidthReader.bindVector
(ColumnMetadata schema, VectorAccessor va) void
BaseScalarReader.bindVector
(ColumnMetadata schema, VectorAccessor va) DictEntryReader.build
(ColumnMetadata schema, VectorAccessor accessor, List<AbstractObjectReader> readers) DictEntryReader.build
(ColumnMetadata schema, VectorAccessor accessor, AbstractObjectReader[] readers) DictReaderImpl.build
(ColumnMetadata schema, VectorAccessor dictAccessor, List<AbstractObjectReader> readers) static AbstractObjectReader
MapReader.build
(ColumnMetadata schema, VectorAccessor mapAccessor, List<AbstractObjectReader> readers) MapReader.build
(ColumnMetadata schema, VectorAccessor mapAccessor, AbstractObjectReader[] readers) static AbstractObjectReader
UnionReaderImpl.build
(ColumnMetadata schema, VectorAccessor va, AbstractObjectReader[] variants) static AbstractObjectReader
ArrayReaderImpl.buildList
(ColumnMetadata schema, VectorAccessor listAccessor, AbstractObjectReader elementReader) Build a list reader.BaseScalarReader.buildOptional
(ColumnMetadata schema, VectorAccessor va, BaseScalarReader reader) static AbstractObjectReader
ArrayReaderImpl.buildRepeatedList
(ColumnMetadata schema, VectorAccessor listAccessor, AbstractObjectReader elementReader) Build a 2+D array reader.BaseScalarReader.buildRequired
(ColumnMetadata schema, VectorAccessor va, BaseScalarReader reader) ArrayReaderImpl.buildScalar
(ColumnMetadata schema, VectorAccessor arrayAccessor, BaseScalarReader elementReader) Build a scalar array for a Repeated type.static AbstractObjectReader
ArrayReaderImpl.buildTuple
(ColumnMetadata schema, VectorAccessor arrayAccessor, AbstractObjectReader elementReader) Build a repeated map reader.AbstractScalarReader.nullReader
(ColumnMetadata schema) ModifierConstructorDescriptionArrayReaderImpl
(ColumnMetadata schema, VectorAccessor va, AbstractObjectReader elementReader) protected
DictEntryReader
(ColumnMetadata schema, VectorAccessor accessor, AbstractObjectReader[] readers) DictReaderImpl
(ColumnMetadata metadata, VectorAccessor va, AbstractTupleReader.TupleObjectReader entryObjectReader) protected
MapReader
(ColumnMetadata schema, AbstractObjectReader[] readers) protected
MapReader
(ColumnMetadata schema, VectorAccessor mapAccessor, AbstractObjectReader[] readers) protected
NullReader
(ColumnMetadata schema) UnionReaderImpl
(ColumnMetadata schema, VectorAccessor va, AbstractObjectReader[] variants) -
Uses of ColumnMetadata in org.apache.drill.exec.vector.accessor.writer
Modifier and TypeFieldDescriptionprotected final ColumnMetadata
MapWriter.mapColumnSchema
protected ColumnMetadata
AbstractScalarWriterImpl.schema
Modifier and TypeMethodDescriptionAbstractArrayWriter.schema()
AbstractObjectWriter.schema()
AbstractScalarWriterImpl.schema()
DictEntryWriter.schema()
MapWriter.schema()
UnionWriterImpl.schema()
Modifier and TypeMethodDescriptionint
AbstractTupleWriter.addColumn
(ColumnMetadata column) AbstractTupleWriter.TupleWriterListener.addColumn
(TupleWriter tuple, ColumnMetadata column) EmptyListShim.addMember
(ColumnMetadata colSchema) SimpleListShim.addMember
(ColumnMetadata colSchema) UnionShim.addMember
(ColumnMetadata colSchema) UnionVectorShim.addMember
(ColumnMetadata schema) UnionWriterImpl.addMember
(ColumnMetadata colSchema) void
AbstractScalarWriterImpl.bindSchema
(ColumnMetadata schema) void
BaseScalarWriter.bindSchema
(ColumnMetadata schema) NullableScalarWriter.build
(ColumnMetadata schema, NullableVector nullableVector, BaseScalarWriter baseWriter) ScalarArrayWriter.build
(ColumnMetadata schema, RepeatedValueVector repeatedVector, BaseScalarWriter baseElementWriter) static AbstractObjectWriter
ColumnWriterFactory.buildColumnWriter
(ColumnMetadata schema, ValueVector vector) ObjectDictWriter.buildDict
(ColumnMetadata metadata, DictVector vector, List<AbstractObjectWriter> keyValueWriters) ObjectDictWriter.buildDictArray
(ColumnMetadata metadata, RepeatedDictVector vector, List<AbstractObjectWriter> keyValueWriters) DictEntryWriter.buildDictEntryWriter
(ColumnMetadata schema, List<AbstractObjectWriter> keyValueWriters, DictVector vector) static AbstractObjectWriter
ColumnWriterFactory.buildDummyColumnWriter
(ColumnMetadata schema) Build a writer for a non-projected column.MapWriter.buildMap
(ColumnMetadata schema, MapVector vector, List<AbstractObjectWriter> writers) MapWriter.buildMapArray
(ColumnMetadata schema, RepeatedMapVector mapVector, List<AbstractObjectWriter> writers) static AbstractObjectWriter
MapWriter.buildMapWriter
(ColumnMetadata schema, AbstractMapVector vector) static AbstractObjectWriter
MapWriter.buildMapWriter
(ColumnMetadata schema, AbstractMapVector vector, List<AbstractObjectWriter> writers) static AbstractObjectWriter
RepeatedListWriter.buildRepeatedList
(ColumnMetadata schema, RepeatedListVector vector, AbstractObjectWriter elementWriter) RepeatedListWriter.defineElement
(ColumnMetadata schema) RepeatedListWriter.ArrayListener.setChild
(ArrayWriter array, ColumnMetadata column) ModifierConstructorDescriptionAbstractArrayWriter
(ColumnMetadata schema, AbstractObjectWriter elementObjWriter, OffsetVectorWriter offsetVectorWriter) protected
ArrayMapWriter
(ColumnMetadata schema, List<AbstractObjectWriter> writers) BaseArrayWriter
(ColumnMetadata schema, UInt4Vector offsetVector, AbstractObjectWriter elementObjWriter) DictEntryWriter
(ColumnMetadata schema, List<AbstractObjectWriter> writers) protected
DummyArrayMapWriter
(ColumnMetadata schema, List<AbstractObjectWriter> writers) protected
DummyMapWriter
(ColumnMetadata schema, List<AbstractObjectWriter> writers) ListWriterImpl
(ColumnMetadata schema, ListVector vector, AbstractObjectWriter memberWriter) protected
MapWriter
(ColumnMetadata schema, List<AbstractObjectWriter> writers) NullableScalarWriter
(ColumnMetadata schema, NullableVector nullableVector, BaseScalarWriter baseWriter) protected
ObjectArrayWriter
(ColumnMetadata schema, UInt4Vector offsetVector, AbstractObjectWriter elementWriter) ObjectDictWriter
(ColumnMetadata schema, UInt4Vector offsetVector, DictEntryWriter.DictEntryObjectWriter entryObjectWriter) protected
RepeatedListWriter
(ColumnMetadata schema, UInt4Vector offsetVector, AbstractObjectWriter elementWriter) ScalarArrayWriter
(ColumnMetadata schema, RepeatedValueVector vector, BaseScalarWriter baseElementWriter) protected
SingleMapWriter
(ColumnMetadata schema, MapVector vector, List<AbstractObjectWriter> writers) UnionWriterImpl
(ColumnMetadata schema) UnionWriterImpl
(ColumnMetadata schema, UnionVector vector, AbstractObjectWriter[] variants) -
Uses of ColumnMetadata in org.apache.drill.exec.vector.accessor.writer.dummy
ModifierConstructorDescriptionDummyArrayWriter
(ColumnMetadata schema, AbstractObjectWriter elementWriter) DummyDictWriter
(ColumnMetadata schema, DictEntryWriter.DictEntryObjectWriter entryObjectWriter) DummyScalarWriter
(ColumnMetadata schema) -
Uses of ColumnMetadata in org.apache.drill.metastore.metadata
Modifier and TypeMethodDescriptionBaseMetadata.getColumn
(SchemaPath name) Metadata.getColumn
(SchemaPath name) Returns metadata description for the specified columnNonInterestingColumnsMetadata.getColumn
(SchemaPath name) -
Uses of ColumnMetadata in org.apache.drill.metastore.util
Modifier and TypeMethodDescriptionstatic ColumnMetadata
SchemaPathUtils.getColumnMetadata
(SchemaPath schemaPath, TupleMetadata schema) ReturnsColumnMetadata
instance obtained from specifiedTupleMetadata schema
which corresponds to the specified column schema path.