Uses of Interface
org.apache.drill.exec.record.metadata.ColumnMetadata
Packages that use ColumnMetadata
Package
Description
Standard type conversion tools for the case in which the input
types are the standard Java types already supported by the
interface.
invalid reference
ValuesWriter
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
Methods in org.apache.drill.exec.physical.impl.scan.convert that return ColumnMetadataMethods in org.apache.drill.exec.physical.impl.scan.convert with parameters of type ColumnMetadataModifier 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
Methods in org.apache.drill.exec.physical.impl.scan.project that return ColumnMetadataModifier and TypeMethodDescriptionAbstractUnresolvedColumn.UnresolvedColumn.metadata()NullColumnLoader.NullColumnSpec.metadata()ResolvedColumn.metadata()Methods in org.apache.drill.exec.physical.impl.scan.project with parameters of type ColumnMetadataConstructors in org.apache.drill.exec.physical.impl.scan.project with parameters of type ColumnMetadataModifierConstructorDescriptionResolvedColumn(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
Classes in org.apache.drill.exec.physical.impl.scan.v3.schema that implement ColumnMetadataModifier and TypeClassDescriptionclassEnhanced form of a dynamic column which records all information from the project list.Methods in org.apache.drill.exec.physical.impl.scan.v3.schema that return ColumnMetadataModifier and TypeMethodDescriptionMutableTupleSchema.ColumnHandle.column()ProjectedColumn.copy()static ColumnMetadataSchemaUtils.getColumnMetadata(String name, org.apache.calcite.rel.type.RelDataType relDataType) Converts specifiedRelDataType relDataTypeintoColumnMetadata.Methods in org.apache.drill.exec.physical.impl.scan.v3.schema with parameters of type ColumnMetadataModifier and TypeMethodDescriptionvoidMutableTupleSchema.add(ColumnMetadata col) DynamicSchemaFilter.buildProjection(ColumnMetadata schemaCol, ColumnMetadata probeCol) static voidSchemaUtils.copyMapProperties(ProjectedColumn source, ColumnMetadata dest) voidProjectionSchemaTracker.expandImplicitCol(ColumnMetadata resolved, ImplicitColumnMarker marker) voidScanSchemaTracker.expandImplicitCol(ColumnMetadata resolved, ImplicitColumnMarker marker) Drill defines a wildcard to expand not just reader columns, but also partition columns.voidSchemaBasedTracker.expandImplicitCol(ColumnMetadata resolved, ImplicitColumnMarker marker) protected ProjectionFilter.ProjResultDynamicSchemaFilter.fromSchema(ColumnMetadata schemaCol, ColumnMetadata probeCol) A column exists in the scan schema, and is concrete.static StringSchemaUtils.implicitColType(ColumnMetadata col) MutableTupleSchema.insert(int posn, ColumnMetadata col) MutableTupleSchema.insert(ColumnMetadata col) static booleanSchemaUtils.isConsistent(ProjectedColumn colReq, ColumnMetadata readCol) Check if the given read column is consistent with the projection requested for that column.static booleanSchemaUtils.isExcludedFromWildcard(ColumnMetadata col) static booleanSchemaUtils.isImplicit(ColumnMetadata col) static voidSchemaUtils.markAsPartition(ColumnMetadata col, int level) static voidSchemaUtils.markExcludeFromWildcard(ColumnMetadata col) static voidSchemaUtils.markImplicit(ColumnMetadata col, String value) static voidSchemaUtils.markProjectAll(ColumnMetadata col) static voidSchemaUtils.mergeColProperties(ColumnMetadata existing, ColumnMetadata revised) DynamicSchemaFilter.DynamicTupleFilter.projection(ColumnMetadata col) DynamicSchemaFilter.RowSchemaFilter.projection(ColumnMetadata col) voidMutableTupleSchema.replace(MutableTupleSchema.ColumnHandle col, ColumnMetadata resolved) voidMutableTupleSchema.resolve(MutableTupleSchema.ColumnHandle col, ColumnMetadata resolved) voidMutableTupleSchema.resolveImplicit(MutableTupleSchema.ColumnHandle col, ColumnMetadata resolved, ImplicitColumnMarker marker) static voidSchemaUtils.verifyCompatibility(ProjectedColumn colReq, ColumnMetadata actual, String source, CustomErrorContext errorContext) Perform the column-level projection as described inSchemaUtils.isConsistent(ProjectedColumn, ColumnMetadata), and raise aUserExceptionif the column is not consistent with projection.static voidSchemaUtils.verifyConsistency(ColumnMetadata existing, ColumnMetadata revised, String source, CustomErrorContext errorContext) static voidSchemaUtils.verifyProjection(ColumnMetadata existing, ColumnMetadata revised, String source, CustomErrorContext errorContext) Constructors in org.apache.drill.exec.physical.impl.scan.v3.schema with parameters of type ColumnMetadata -
Uses of ColumnMetadata in org.apache.drill.exec.physical.resultSet.impl
Fields in org.apache.drill.exec.physical.resultSet.impl declared as ColumnMetadataModifier and TypeFieldDescriptionprotected final ColumnMetadataTupleState.DictColumnState.outputSchemaprotected final ColumnMetadataTupleState.MapColumnState.outputSchemafinal ColumnMetadataProjectionFilter.ProjResult.projectionMethods in org.apache.drill.exec.physical.resultSet.impl that return ColumnMetadataModifier and TypeMethodDescriptionabstract ColumnMetadataColumnState.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()Methods in org.apache.drill.exec.physical.resultSet.impl with parameters of type ColumnMetadataModifier and TypeMethodDescriptionContainerState.addColumn(ColumnMetadata columnSchema) TupleState.addColumn(TupleWriter tupleWriter, ColumnMetadata columnSchema) ListState.addMember(ColumnMetadata member) UnionState.addMember(ColumnMetadata member) abstract intTupleState.addOutputColumn(ValueVector vector, ColumnMetadata colSchema) intTupleState.DictArrayState.addOutputColumn(ValueVector vector, ColumnMetadata colSchema) intTupleState.MapState.addOutputColumn(ValueVector vector, ColumnMetadata colSchema) intTupleState.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 voidProjectionFilter.BaseSchemaProjectionFilter.validateColumn(ColumnMetadata schemaCol, ColumnMetadata readerCol) protected voidProjectionFilter.BaseSchemaProjectionFilter.validateMap(ColumnMetadata schemaCol) SingleVectorState.vectorState(ColumnMetadata schema, WriterEvents writer, ValueVector mainVector) Constructors in org.apache.drill.exec.physical.resultSet.impl with parameters of type ColumnMetadataModifierConstructorDescriptionProjResult(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
Fields in org.apache.drill.exec.physical.resultSet.model declared as ColumnMetadataModifier and TypeFieldDescriptionfinal ColumnMetadataMetadataProvider.VectorDescrip.metadataprotected final ColumnMetadataBaseTupleModel.BaseColumnModel.schemaExtended schema associated with a column.Methods in org.apache.drill.exec.physical.resultSet.model that return ColumnMetadataModifier 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()Methods in org.apache.drill.exec.physical.resultSet.model with parameters of type ColumnMetadataModifier and TypeMethodDescriptionprotected AbstractObjectReaderReaderBuilder.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 MetadataProviderMetadataProvider.MetadataCreator.makeProvider(ColumnMetadata colMetadata) static MetadataProviderMetadataProvider.MetadataRetrieval.makeProvider(ColumnMetadata colMetadata) Constructors in org.apache.drill.exec.physical.resultSet.model with parameters of type ColumnMetadataModifierConstructorDescriptionArraySchemaRetrieval(ColumnMetadata arraySchema) BaseColumnModel(ColumnMetadata schema) VectorDescrip(MetadataProvider provider, ColumnMetadata metadata) -
Uses of ColumnMetadata in org.apache.drill.exec.physical.resultSet.model.hyper
Methods in org.apache.drill.exec.physical.resultSet.model.hyper with parameters of type ColumnMetadataModifier and TypeMethodDescriptionprotected AbstractObjectReaderHyperReaderBuilder.buildVectorReader(VectorAccessor va, ColumnMetadata metadata) -
Uses of ColumnMetadata in org.apache.drill.exec.physical.resultSet.project
Methods in org.apache.drill.exec.physical.resultSet.project with parameters of type ColumnMetadataModifier and TypeMethodDescriptionbooleanImpliedTupleRequest.enforceProjection(ColumnMetadata columnSchema, CustomErrorContext errorContext) booleanRequestedTuple.enforceProjection(ColumnMetadata columnSchema, CustomErrorContext errorContext) booleanRequestedTupleImpl.enforceProjection(ColumnMetadata columnSchema, CustomErrorContext errorContext) static booleanProjections.excludeFromWildcard(ColumnMetadata col) Reports whether the column is a special column which should not be expanded in a wildcard.static booleanProjectionChecker.isConsistent(RequestedColumn colReq, ColumnMetadata readCol) Check if the given read column is consistent with the projection requested for that column.static booleanProjectionChecker.isConsistent(RequestedTuple tuple, ColumnMetadata readCol) Check if the given read column is consistent with the projection requested for a tuple.booleanImpliedTupleRequest.isProjected(ColumnMetadata columnSchema) booleanRequestedTuple.isProjected(ColumnMetadata columnSchema) booleanRequestedTupleImpl.isProjected(ColumnMetadata columnSchema) static voidProjectionChecker.validateProjection(RequestedColumn colReq, ColumnMetadata readCol) static voidProjectionChecker.validateProjection(RequestedColumn colReq, ColumnMetadata readCol, CustomErrorContext errorContext) Perform the column-level projection as described inProjectionChecker.isConsistent(RequestedColumn, ColumnMetadata), and raise aUserExceptionif the column is not consistent with projection. -
Uses of ColumnMetadata in org.apache.drill.exec.physical.rowSet
Methods in org.apache.drill.exec.physical.rowSet that return ColumnMetadata -
Uses of ColumnMetadata in org.apache.drill.exec.record
Methods in org.apache.drill.exec.record with parameters of type ColumnMetadataModifier 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
Classes in org.apache.drill.exec.record.metadata that implement ColumnMetadataModifier and TypeClassDescriptionclassAbstract definition of column metadata.classDescribes a base column type for map, dict, repeated map and repeated dict.classclassA dynamic column has a name but not a type.classDescribes a map and repeated map.classPrimitive (non-map) column.classclassMethods in org.apache.drill.exec.record.metadata that return ColumnMetadataModifier 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_ARRAYcolumns.RepeatedListColumnMetadata.childSchema()ColumnMetadata.cloneEmpty()Create an empty version of this column.DictColumnMetadata.cloneEmpty()DynamicColumn.cloneEmpty()MapColumnMetadata.cloneEmpty()PrimitiveColumnMetadata.cloneEmpty()RepeatedListColumnMetadata.cloneEmpty()VariantColumnMetadata.cloneEmpty()static ColumnMetadataMetadataUtils.cloneMapWithSchema(ColumnMetadata source, TupleMetadata members) ColumnMetadata.copy()DictColumnMetadata.copy()DynamicColumn.copy()MapColumnMetadata.copy()PrimitiveColumnMetadata.copy()RepeatedListColumnMetadata.copy()VariantColumnMetadata.copy()static ColumnMetadataMetadataUtils.diffMap(ColumnMetadata map, ColumnMetadata other) static ColumnMetadataMetadataUtils.fromField(MaterializedField field) Create a column metadata object that holds the givenMaterializedField.static ColumnMetadataMetadataUtils.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 ColumnMetadataVariantSchema.memberMetadata(TypeProtos.MinorType type) PrimitiveColumnMetadata.mergeWith(MaterializedField field) TupleMetadata.metadata(int index) TupleSchema.metadata(int index) static ColumnMetadataMetadataUtils.newDecimal(String name, TypeProtos.DataMode mode, int precision, int scale) static ColumnMetadataMetadataUtils.newDecimal(String name, TypeProtos.MinorType type, TypeProtos.DataMode mode, int precision, int scale) static ColumnMetadataMetadataUtils.newDynamic(String name) static ColumnMetadataMetadataUtils.newMapArray(String name) static ColumnMetadataMetadataUtils.newMapArray(String name, TupleMetadata schema) TupleMetadata.parent()VariantMetadata.parent()Return the column that defines this variant structureVariantSchema.parent()DictColumnMetadata.valueColumnMetadata()static ColumnMetadataMetadataUtils.wildcard()Methods in org.apache.drill.exec.record.metadata that return types with arguments of type ColumnMetadataModifier 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()Methods in org.apache.drill.exec.record.metadata with parameters of type ColumnMetadataModifier and TypeMethodDescriptionSchemaBuilder.add(ColumnMetadata column) voidTupleSchema.add(ColumnMetadata md) Add a column metadata column created by the caller.voidDictBuilder.addColumn(ColumnMetadata column) voidMapBuilder.addColumn(ColumnMetadata column) voidRepeatedListBuilder.addColumn(ColumnMetadata column) voidSchemaBuilder.addColumn(ColumnMetadata column) voidTupleBuilder.addColumn(ColumnMetadata column) intTupleMetadata.addColumn(ColumnMetadata column) intTupleSchema.addColumn(ColumnMetadata column) voidUnionBuilder.addColumn(ColumnMetadata column) voidVariantMetadata.addType(ColumnMetadata col) Add a column for any supported type to the variant.voidVariantSchema.addType(ColumnMetadata col) voidRepeatedListColumnMetadata.childSchema(ColumnMetadata childMetadata) static ColumnMetadataMetadataUtils.cloneMapWithSchema(ColumnMetadata source, TupleMetadata members) static ColumnMetadataMetadataUtils.diffMap(ColumnMetadata map, ColumnMetadata other) TupleMetadata.fullName(ColumnMetadata column) Full name of the column.TupleSchema.fullName(ColumnMetadata column) booleanAbstractColumnMetadata.isEquivalent(ColumnMetadata o) booleanAbstractMapColumnMetadata.isEquivalent(ColumnMetadata o) booleanColumnMetadata.isEquivalent(ColumnMetadata other) Report whether one column is equivalent to another.booleanDynamicColumn.isEquivalent(ColumnMetadata o) booleanPrimitiveColumnMetadata.isEquivalent(ColumnMetadata o) booleanRepeatedListColumnMetadata.isEquivalent(ColumnMetadata o) booleanVariantColumnMetadata.isEquivalent(ColumnMetadata o) static booleanMetadataUtils.isRepeatedList(ColumnMetadata col) static booleanMetadataUtils.isScalar(ColumnMetadata col) static booleanMetadataUtils.isWildcard(ColumnMetadata col) static RepeatedListColumnMetadataMetadataUtils.newRepeatedList(String name, ColumnMetadata child) voidTupleMetadata.replace(ColumnMetadata replaceWith) voidTupleSchema.replace(ColumnMetadata replaceWith) Method parameters in org.apache.drill.exec.record.metadata with type arguments of type ColumnMetadataModifier and TypeMethodDescriptionstatic TupleSchemaMetadataUtils.fromColumns(List<ColumnMetadata> columns) Create a tuple given the list of columns that make up the tuple.Constructors in org.apache.drill.exec.record.metadata with parameters of type ColumnMetadataModifierConstructorDescriptionRepeatedListColumnMetadata(String name, ColumnMetadata childSchema) -
Uses of ColumnMetadata in org.apache.drill.exec.record.metadata.schema.parser
Methods in org.apache.drill.exec.record.metadata.schema.parser that return ColumnMetadataModifier and TypeMethodDescriptionstatic ColumnMetadataSchemaExprParser.parseColumn(String column) Parses string definition of the column and converts it intoColumnMetadatainstance.static ColumnMetadataSchemaExprParser.parseColumn(String name, String type, TypeProtos.DataMode mode) Parses given column name, type and mode intoColumnMetadatainstance.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
Methods in org.apache.drill.exec.store.avro with parameters of type ColumnMetadataModifier and TypeMethodDescriptionAvroColumnConverterFactory.buildScalar(ColumnMetadata readerSchema, ValueWriter writer) -
Uses of ColumnMetadata in org.apache.drill.exec.store.cassandra
Methods in org.apache.drill.exec.store.cassandra with parameters of type ColumnMetadataModifier and TypeMethodDescriptionCassandraColumnConverterFactory.buildScalar(ColumnMetadata readerSchema, ValueWriter writer) -
Uses of ColumnMetadata in org.apache.drill.exec.store.easy.json.extended
Methods in org.apache.drill.exec.store.easy.json.extended with parameters of type ColumnMetadataModifier 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
Methods in org.apache.drill.exec.store.easy.json.loader that return ColumnMetadataModifier and TypeMethodDescriptionFieldDefn.providedColumn()protected ColumnMetadataBaseFieldFactory.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) Methods in org.apache.drill.exec.store.easy.json.loader with parameters of type ColumnMetadataModifier 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 ElementParserBaseFieldFactory.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 ElementParserBaseFieldFactory.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 ColumnMetadataBaseFieldFactory.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
Methods in org.apache.drill.exec.store.easy.json.values that return ColumnMetadata -
Uses of ColumnMetadata in org.apache.drill.exec.store.elasticsearch
Methods in org.apache.drill.exec.store.elasticsearch with parameters of type ColumnMetadataModifier and TypeMethodDescriptionElasticsearchColumnConverterFactory.buildScalar(ColumnMetadata readerSchema, ValueWriter writer) -
Uses of ColumnMetadata in org.apache.drill.exec.store.hive
Methods in org.apache.drill.exec.store.hive that return ColumnMetadataModifier and TypeMethodDescriptionstatic ColumnMetadataHiveUtilities.getColumnMetadata(HiveToRelDataTypeConverter dataTypeConverter, org.apache.hadoop.hive.metastore.api.FieldSchema column) Converts specifiedFieldSchema columnintoColumnMetadata. -
Uses of ColumnMetadata in org.apache.drill.exec.store.iceberg.read
Methods in org.apache.drill.exec.store.iceberg.read that return ColumnMetadataModifier and TypeMethodDescriptionstatic ColumnMetadataIcebergColumnConverterFactory.getColumnMetadata(org.apache.iceberg.types.Types.NestedField field) Methods in org.apache.drill.exec.store.iceberg.read with parameters of type ColumnMetadataModifier and TypeMethodDescriptionIcebergColumnConverterFactory.buildScalar(ColumnMetadata readerSchema, ValueWriter writer) -
Uses of ColumnMetadata in org.apache.drill.exec.store.ischema
Constructors in org.apache.drill.exec.store.ischema with parameters of type ColumnMetadataModifierConstructorDescriptionColumn(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
Methods in org.apache.drill.exec.vector.accessor that return ColumnMetadataModifier and TypeMethodDescriptionColumnReader.schema()ColumnWriter.schema()Returns the schema of the column associated with this writer.Methods in org.apache.drill.exec.vector.accessor with parameters of type ColumnMetadataModifier and TypeMethodDescriptionintTupleWriter.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) voidColumnAccessors.Decimal18ColumnReader.bindVector(ColumnMetadata schema, VectorAccessor va) voidColumnAccessors.Decimal28SparseColumnReader.bindVector(ColumnMetadata schema, VectorAccessor va) voidColumnAccessors.Decimal38SparseColumnReader.bindVector(ColumnMetadata schema, VectorAccessor va) voidColumnAccessors.Decimal9ColumnReader.bindVector(ColumnMetadata schema, VectorAccessor va) voidColumnAccessors.VarDecimalColumnReader.bindVector(ColumnMetadata schema, VectorAccessor va) static UnsupportedConversionErrorUnsupportedConversionError.nullError(ColumnMetadata schema) static UnsupportedConversionErrorUnsupportedConversionError.readError(ColumnMetadata schema, String javaType) static InvalidConversionErrorInvalidConversionError.writeError(ColumnMetadata schema, Object value) static InvalidConversionErrorInvalidConversionError.writeError(ColumnMetadata schema, Object value, Exception e) static UnsupportedConversionErrorUnsupportedConversionError.writeError(ColumnMetadata schema, String javaType) -
Uses of ColumnMetadata in org.apache.drill.exec.vector.accessor.reader
Fields in org.apache.drill.exec.vector.accessor.reader declared as ColumnMetadataModifier and TypeFieldDescriptionprotected final ColumnMetadataAbstractScalarReader.NullReader.schemaprotected ColumnMetadataBaseScalarReader.schemaprotected final ColumnMetadataMapReader.schemaMethods in org.apache.drill.exec.vector.accessor.reader that return ColumnMetadataModifier and TypeMethodDescriptionAbstractObjectReader.schema()AbstractScalarReader.NullReader.schema()ArrayReaderImpl.schema()BaseScalarReader.schema()DictEntryReader.schema()MapReader.schema()OffsetVectorReader.schema()UnionReaderImpl.schema()Methods in org.apache.drill.exec.vector.accessor.reader with parameters of type ColumnMetadataModifier and TypeMethodDescriptionvoidBaseScalarReader.BaseVarWidthReader.bindVector(ColumnMetadata schema, VectorAccessor va) voidBaseScalarReader.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 AbstractObjectReaderMapReader.build(ColumnMetadata schema, VectorAccessor mapAccessor, List<AbstractObjectReader> readers) MapReader.build(ColumnMetadata schema, VectorAccessor mapAccessor, AbstractObjectReader[] readers) static AbstractObjectReaderUnionReaderImpl.build(ColumnMetadata schema, VectorAccessor va, AbstractObjectReader[] variants) static AbstractObjectReaderArrayReaderImpl.buildList(ColumnMetadata schema, VectorAccessor listAccessor, AbstractObjectReader elementReader) Build a list reader.BaseScalarReader.buildOptional(ColumnMetadata schema, VectorAccessor va, BaseScalarReader reader) static AbstractObjectReaderArrayReaderImpl.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 AbstractObjectReaderArrayReaderImpl.buildTuple(ColumnMetadata schema, VectorAccessor arrayAccessor, AbstractObjectReader elementReader) Build a repeated map reader.AbstractScalarReader.nullReader(ColumnMetadata schema) Constructors in org.apache.drill.exec.vector.accessor.reader with parameters of type ColumnMetadataModifierConstructorDescriptionArrayReaderImpl(ColumnMetadata schema, VectorAccessor va, AbstractObjectReader elementReader) protectedDictEntryReader(ColumnMetadata schema, VectorAccessor accessor, AbstractObjectReader[] readers) DictReaderImpl(ColumnMetadata metadata, VectorAccessor va, AbstractTupleReader.TupleObjectReader entryObjectReader) protectedMapReader(ColumnMetadata schema, AbstractObjectReader[] readers) protectedMapReader(ColumnMetadata schema, VectorAccessor mapAccessor, AbstractObjectReader[] readers) protectedNullReader(ColumnMetadata schema) UnionReaderImpl(ColumnMetadata schema, VectorAccessor va, AbstractObjectReader[] variants) -
Uses of ColumnMetadata in org.apache.drill.exec.vector.accessor.writer
Fields in org.apache.drill.exec.vector.accessor.writer declared as ColumnMetadataModifier and TypeFieldDescriptionprotected final ColumnMetadataMapWriter.mapColumnSchemaprotected ColumnMetadataAbstractScalarWriterImpl.schemaMethods in org.apache.drill.exec.vector.accessor.writer that return ColumnMetadataModifier and TypeMethodDescriptionAbstractArrayWriter.schema()AbstractObjectWriter.schema()AbstractScalarWriterImpl.schema()DictEntryWriter.schema()MapWriter.schema()UnionWriterImpl.schema()Methods in org.apache.drill.exec.vector.accessor.writer with parameters of type ColumnMetadataModifier and TypeMethodDescriptionintAbstractTupleWriter.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) voidAbstractScalarWriterImpl.bindSchema(ColumnMetadata schema) voidBaseScalarWriter.bindSchema(ColumnMetadata schema) NullableScalarWriter.build(ColumnMetadata schema, NullableVector nullableVector, BaseScalarWriter baseWriter) ScalarArrayWriter.build(ColumnMetadata schema, RepeatedValueVector repeatedVector, BaseScalarWriter baseElementWriter) static AbstractObjectWriterColumnWriterFactory.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 AbstractObjectWriterColumnWriterFactory.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 AbstractObjectWriterMapWriter.buildMapWriter(ColumnMetadata schema, AbstractMapVector vector) static AbstractObjectWriterMapWriter.buildMapWriter(ColumnMetadata schema, AbstractMapVector vector, List<AbstractObjectWriter> writers) static AbstractObjectWriterRepeatedListWriter.buildRepeatedList(ColumnMetadata schema, RepeatedListVector vector, AbstractObjectWriter elementWriter) RepeatedListWriter.defineElement(ColumnMetadata schema) RepeatedListWriter.ArrayListener.setChild(ArrayWriter array, ColumnMetadata column) Constructors in org.apache.drill.exec.vector.accessor.writer with parameters of type ColumnMetadataModifierConstructorDescriptionAbstractArrayWriter(ColumnMetadata schema, AbstractObjectWriter elementObjWriter, OffsetVectorWriter offsetVectorWriter) protectedArrayMapWriter(ColumnMetadata schema, List<AbstractObjectWriter> writers) BaseArrayWriter(ColumnMetadata schema, UInt4Vector offsetVector, AbstractObjectWriter elementObjWriter) DictEntryWriter(ColumnMetadata schema, List<AbstractObjectWriter> writers) protectedDummyArrayMapWriter(ColumnMetadata schema, List<AbstractObjectWriter> writers) protectedDummyMapWriter(ColumnMetadata schema, List<AbstractObjectWriter> writers) ListWriterImpl(ColumnMetadata schema, ListVector vector, AbstractObjectWriter memberWriter) protectedMapWriter(ColumnMetadata schema, List<AbstractObjectWriter> writers) NullableScalarWriter(ColumnMetadata schema, NullableVector nullableVector, BaseScalarWriter baseWriter) protectedObjectArrayWriter(ColumnMetadata schema, UInt4Vector offsetVector, AbstractObjectWriter elementWriter) ObjectDictWriter(ColumnMetadata schema, UInt4Vector offsetVector, DictEntryWriter.DictEntryObjectWriter entryObjectWriter) protectedRepeatedListWriter(ColumnMetadata schema, UInt4Vector offsetVector, AbstractObjectWriter elementWriter) ScalarArrayWriter(ColumnMetadata schema, RepeatedValueVector vector, BaseScalarWriter baseElementWriter) protectedSingleMapWriter(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
Constructors in org.apache.drill.exec.vector.accessor.writer.dummy with parameters of type ColumnMetadataModifierConstructorDescriptionDummyArrayWriter(ColumnMetadata schema, AbstractObjectWriter elementWriter) DummyDictWriter(ColumnMetadata schema, DictEntryWriter.DictEntryObjectWriter entryObjectWriter) DummyScalarWriter(ColumnMetadata schema) -
Uses of ColumnMetadata in org.apache.drill.metastore.metadata
Methods in org.apache.drill.metastore.metadata that return ColumnMetadataModifier 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
Methods in org.apache.drill.metastore.util that return ColumnMetadataModifier and TypeMethodDescriptionstatic ColumnMetadataSchemaPathUtils.getColumnMetadata(SchemaPath schemaPath, TupleMetadata schema) ReturnsColumnMetadatainstance obtained from specifiedTupleMetadata schemawhich corresponds to the specified column schema path.