org.apache.drill.exec.physical.impl.scan.v3.schema

Class DynamicSchemaFilter

java.lang.Object

org.apache.drill.exec.physical.impl.scan.v3.schema.DynamicSchemaFilter

All Implemented Interfaces:

ProjectionFilter

Direct Known Subclasses:

DynamicSchemaFilter.DynamicTupleFilter, DynamicSchemaFilter.RowSchemaFilter

public abstract class DynamicSchemaFilter
extends Object
implements ProjectionFilter

Projection filter based on the scan schema which typically starts as fully dynamic, then becomes more concrete as the scan progresses. Enforces that projected columns must be consistent with either projection, or the existing concrete schema for that columns.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	DynamicSchemaFilter.DynamicTupleFilter Filter for a map, represented by a TupleMetadata.
static class	DynamicSchemaFilter.NewColumnsMode Describes how to handle candidate columns not currently in the scan schema, which turns out to be a surprisingly complex question.
static class	DynamicSchemaFilter.RowSchemaFilter Filter for the top-level dynamic schema.

Nested classes/interfaces inherited from interface org.apache.drill.exec.physical.resultSet.impl.ProjectionFilter

ProjectionFilter.BaseSchemaProjectionFilter, ProjectionFilter.CompoundProjectionFilter, ProjectionFilter.DirectProjectionFilter, ProjectionFilter.ImplicitProjectionFilter, ProjectionFilter.ProjResult, ProjectionFilter.SchemaProjectionFilter, ProjectionFilter.TypeProjectionFilter

Field Summary

Fields

Modifier and Type	Field and Description
protected CustomErrorContext	errorContext
protected DynamicSchemaFilter.NewColumnsMode	newColumnsMode
protected String	source

Fields inherited from interface org.apache.drill.exec.physical.resultSet.impl.ProjectionFilter

logger, NOT_PROJECTED, PROJECT_ALL, PROJECT_NONE, PROJECTED

Constructor Summary

Constructors

Constructor and Description
DynamicSchemaFilter(CustomErrorContext errorContext, String source, DynamicSchemaFilter.NewColumnsMode newColumnsMode)

Method Summary

Modifier and Type	Method and Description
ProjectionFilter.ProjResult	buildProjection(ColumnMetadata schemaCol, ColumnMetadata probeCol)
protected ProjectionFilter.ProjResult	fromSchema(ColumnMetadata schemaCol, ColumnMetadata probeCol) A column exists in the scan schema, and is concrete.
boolean	isProjected(String colName)
protected ProjectionFilter.ProjResult	newColumnProjection()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.apache.drill.exec.physical.resultSet.impl.ProjectionFilter

definedSchemaFilter, isEmpty, projection, projectionFilter, providedSchemaFilter

Field Detail

errorContext

protected final CustomErrorContext errorContext

source

protected final String source

newColumnsMode

protected final DynamicSchemaFilter.NewColumnsMode newColumnsMode

Constructor Detail

DynamicSchemaFilter

public DynamicSchemaFilter(CustomErrorContext errorContext,
                           String source,
                           DynamicSchemaFilter.NewColumnsMode newColumnsMode)

Method Detail

buildProjection

public ProjectionFilter.ProjResult buildProjection(ColumnMetadata schemaCol,
                                                   ColumnMetadata probeCol)

newColumnProjection

protected ProjectionFilter.ProjResult newColumnProjection()

fromSchema

protected ProjectionFilter.ProjResult fromSchema(ColumnMetadata schemaCol,
                                                 ColumnMetadata probeCol)

A column exists in the scan schema, and is concrete. The proposed column can be projected. Verify consistency. The reader should not be proposing a column with the wrong type or mode since it was told the reader input schema, and that schema was derived from a provided schema (which should be acceptable to the reader) or by a prior reader in the same scan.

isProjected

public boolean isProjected(String colName)

Specified by:

isProjected in interface ProjectionFilter