Package 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	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	Description
static final org.slf4j.Logger	logger
static final ProjectionFilter.ProjResult	NOT_PROJECTED
static final ProjectionFilter	PROJECT_ALL
static final ProjectionFilter	PROJECT_NONE
static final ProjectionFilter.ProjResult	PROJECTED

Method Summary

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

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 Details

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)