org.apache.drill.exec.physical.resultSet.impl

Interface ProjectionFilter

All Known Implementing Classes:

DynamicSchemaFilter, DynamicSchemaFilter.DynamicTupleFilter, DynamicSchemaFilter.RowSchemaFilter, ProjectionFilter.BaseSchemaProjectionFilter, ProjectionFilter.CompoundProjectionFilter, ProjectionFilter.DirectProjectionFilter, ProjectionFilter.ImplicitProjectionFilter, ProjectionFilter.SchemaProjectionFilter, ProjectionFilter.TypeProjectionFilter

public interface ProjectionFilter

Provides a variety of ways to filter columns: no filtering, filter by (parsed) projection list, or filter by projection list and provided schema. Enforces consistency of actual reader schema and projection list and/or provided schema.

Projection filters should not need to be extensible; filtering depends only on projection and provided schema.

Nested Class Summary

Nested Classes

Modifier and Type	Interface and Description
static class	ProjectionFilter.BaseSchemaProjectionFilter Schema-based projection.
static class	ProjectionFilter.CompoundProjectionFilter Compound filter for combining direct and provided schema projections.
static class	ProjectionFilter.DirectProjectionFilter Projection filter based on the (parsed) projection list.
static class	ProjectionFilter.ImplicitProjectionFilter Implied projection: either project all or project none.
static class	ProjectionFilter.ProjResult
static class	ProjectionFilter.SchemaProjectionFilter Projection filter in which a schema exactly defines the set of allowed columns, and their types.
static class	ProjectionFilter.TypeProjectionFilter Projection based on a non-strict provided schema which enforces the type of known columns, but has no opinion about additional columns.

Field Summary

Fields

Modifier and Type	Field and Description
static org.slf4j.Logger	logger
static ProjectionFilter.ProjResult	NOT_PROJECTED
static ProjectionFilter	PROJECT_ALL
static ProjectionFilter	PROJECT_NONE
static ProjectionFilter.ProjResult	PROJECTED

Method Summary

Modifier and Type	Method and Description
static ProjectionFilter	definedSchemaFilter(TupleMetadata definedSchema, CustomErrorContext errorContext)
boolean	isEmpty()
boolean	isProjected(String colName)
ProjectionFilter.ProjResult	projection(ColumnMetadata columnSchema)
static ProjectionFilter	projectionFilter(RequestedTuple tupleProj, CustomErrorContext errorContext)
static ProjectionFilter	providedSchemaFilter(RequestedTuple tupleProj, TupleMetadata providedSchema, CustomErrorContext errorContext)

Field Detail

logger

static final org.slf4j.Logger logger

PROJECT_ALL

static final ProjectionFilter PROJECT_ALL

PROJECT_NONE

static final ProjectionFilter PROJECT_NONE

NOT_PROJECTED

static final ProjectionFilter.ProjResult NOT_PROJECTED

PROJECTED

static final ProjectionFilter.ProjResult PROJECTED

Method Detail

projection

ProjectionFilter.ProjResult projection(ColumnMetadata columnSchema)

isProjected

boolean isProjected(String colName)

isEmpty

boolean isEmpty()

projectionFilter

static ProjectionFilter projectionFilter(RequestedTuple tupleProj,
                                         CustomErrorContext errorContext)

providedSchemaFilter

static ProjectionFilter providedSchemaFilter(RequestedTuple tupleProj,
                                             TupleMetadata providedSchema,
                                             CustomErrorContext errorContext)

definedSchemaFilter

static ProjectionFilter definedSchemaFilter(TupleMetadata definedSchema,
                                            CustomErrorContext errorContext)