Uses of Class
org.apache.drill.common.expression.SchemaPath

Packages that use SchemaPath

Package	Description
org.apache.calcite.jdbc
org.apache.drill.common.expression	Logical expression tree representation.
org.apache.drill.common.expression.visitors	Visitors for validating or optimizing logical expressions.
org.apache.drill.common.logical.data	Logical operators in a query graph.
org.apache.drill.exec.compile.sig	TODO - write docs for this package
org.apache.drill.exec.expr	Drill expression materialization and evaluation facilities.
org.apache.drill.exec.expr.fn.interpreter
org.apache.drill.exec.metastore.analyze
org.apache.drill.exec.metastore.store
org.apache.drill.exec.physical.base
org.apache.drill.exec.physical.config
org.apache.drill.exec.physical.impl
org.apache.drill.exec.physical.impl.aggregate
org.apache.drill.exec.physical.impl.orderedpartitioner
org.apache.drill.exec.physical.impl.partitionsender
org.apache.drill.exec.physical.impl.protocol	Defines a revised implementation of the Drill RecordBatch protocol.
org.apache.drill.exec.physical.impl.scan.project	Provides run-time semantic analysis of the projection list for the scan operator.
org.apache.drill.exec.physical.impl.scan.v3	Provides the "version 3" scan framework (which can also be thought of as EVF version 2).
org.apache.drill.exec.physical.impl.scan.v3.schema	Provides run-time semantic analysis of the projection list for the scan operator.
org.apache.drill.exec.physical.impl.unorderedreceiver
org.apache.drill.exec.physical.impl.validate
org.apache.drill.exec.physical.impl.window
org.apache.drill.exec.physical.impl.xsort
org.apache.drill.exec.physical.resultSet.project
org.apache.drill.exec.planner
org.apache.drill.exec.planner.common
org.apache.drill.exec.planner.index
org.apache.drill.exec.planner.index.generators
org.apache.drill.exec.planner.logical
org.apache.drill.exec.planner.sql
org.apache.drill.exec.planner.sql.parser
org.apache.drill.exec.record
org.apache.drill.exec.store
org.apache.drill.exec.store.bson
org.apache.drill.exec.store.dfs
org.apache.drill.exec.store.dfs.easy
org.apache.drill.exec.store.direct
org.apache.drill.exec.store.druid
org.apache.drill.exec.store.easy.json
org.apache.drill.exec.store.easy.text
org.apache.drill.exec.store.enumerable
org.apache.drill.exec.store.hbase
org.apache.drill.exec.store.hive
org.apache.drill.exec.store.hive.readers
org.apache.drill.exec.store.http
org.apache.drill.exec.store.iceberg
org.apache.drill.exec.store.iceberg.format
org.apache.drill.exec.store.ischema
org.apache.drill.exec.store.jdbc
org.apache.drill.exec.store.kafka	Kafka storage plugin.
org.apache.drill.exec.store.kudu
org.apache.drill.exec.store.ltsv
org.apache.drill.exec.store.mapr
org.apache.drill.exec.store.mapr.db
org.apache.drill.exec.store.mapr.db.binary
org.apache.drill.exec.store.mapr.db.json
org.apache.drill.exec.store.mapr.db.util
org.apache.drill.exec.store.mapr.streams
org.apache.drill.exec.store.mock	Defines a mock data source which generates dummy test data for use in testing.
org.apache.drill.exec.store.mongo	MongoDB storage plugin.
org.apache.drill.exec.store.openTSDB
org.apache.drill.exec.store.parquet
org.apache.drill.exec.store.parquet.columnreaders
org.apache.drill.exec.store.parquet.metadata
org.apache.drill.exec.store.parquet2
org.apache.drill.exec.store.phoenix
org.apache.drill.exec.store.splunk
org.apache.drill.exec.store.sys
org.apache.drill.exec.util
org.apache.drill.exec.vector.complex
org.apache.drill.exec.vector.complex.fn
org.apache.drill.metastore.metadata
org.apache.drill.metastore.util

Uses of SchemaPath in org.apache.calcite.jdbc

Methods in org.apache.calcite.jdbc that return SchemaPath

Modifier and Type	Method and Description
SchemaPath	DynamicRootSchema.resolveTableAlias(String alias)

Uses of SchemaPath in org.apache.drill.common.expression

Subclasses of SchemaPath in org.apache.drill.common.expression

Modifier and Type	Class and Description
class	FieldReference

Fields in org.apache.drill.common.expression declared as SchemaPath

Modifier and Type	Field and Description
static SchemaPath	SchemaPath.STAR_COLUMN

Methods in org.apache.drill.common.expression that return SchemaPath

Modifier and Type	Method and Description
static SchemaPath	SchemaPath.create(UserBitShared.NamePart namePart)
SchemaPath	SchemaPath.De.deserialize(com.fasterxml.jackson.core.JsonParser jp, com.fasterxml.jackson.databind.DeserializationContext ctxt)
SchemaPath	SchemaPath.getChild(int index)
SchemaPath	SchemaPath.getChild(int index, Object originalValue, TypeProtos.MajorType valueType)
SchemaPath	SchemaPath.getChild(String childPath)
SchemaPath	SchemaPath.getChild(String childPath, Object originalValue, TypeProtos.MajorType valueType)
static SchemaPath	SchemaPath.getCompoundPath(int n, String... path) Constructs SchemaPath based on given path array up to nth element (inclusively).
static SchemaPath	SchemaPath.getCompoundPath(String... path)
SchemaPath	TypedFieldExpr.getPath()
static SchemaPath	SchemaPath.getSimplePath(String name)
SchemaPath	SchemaPath.getUnIndexed() Returns schema path with for arrays without index.
static SchemaPath	SchemaPath.parseFromString(String expr) Parses input string using the same rules which are used for the field in the query.

Methods in org.apache.drill.common.expression with parameters of type SchemaPath

Modifier and Type	Method and Description
boolean	SchemaPath.contains(SchemaPath path)
Void	ExpressionStringBuilder.visitSchemaPath(SchemaPath path, StringBuilder sb)

Constructors in org.apache.drill.common.expression with parameters of type SchemaPath

Constructor and Description
FieldReference(SchemaPath sp)
SchemaPath(SchemaPath path)
TypedFieldExpr(SchemaPath path, TypeProtos.MajorType type)

Uses of SchemaPath in org.apache.drill.common.expression.visitors

Methods in org.apache.drill.common.expression.visitors with parameters of type SchemaPath

Modifier and Type	Method and Description
abstract T	SimpleExprVisitor.visitSchemaPath(SchemaPath path)
Boolean	AggregateChecker.visitSchemaPath(SchemaPath path, ErrorCollector errors)
Void	ExpressionValidator.visitSchemaPath(SchemaPath path, ErrorCollector errors)
T	AbstractExprVisitor.visitSchemaPath(SchemaPath path, VAL value)
T	ExprVisitor.visitSchemaPath(SchemaPath path, VAL value)
T	SimpleExprVisitor.visitSchemaPath(SchemaPath path, Void value)

Uses of SchemaPath in org.apache.drill.common.logical.data

Methods in org.apache.drill.common.logical.data that return SchemaPath

Modifier and Type	Method and Description
SchemaPath	Unnest.getColumn()

Constructors in org.apache.drill.common.logical.data with parameters of type SchemaPath

Constructor and Description
Unnest(SchemaPath column)

Uses of SchemaPath in org.apache.drill.exec.compile.sig

Methods in org.apache.drill.exec.compile.sig with parameters of type SchemaPath

Modifier and Type	Method and Description
Boolean	ConstantExpressionIdentifier.visitSchemaPath(SchemaPath path, IdentityHashMap<LogicalExpression,Object> value)

Uses of SchemaPath in org.apache.drill.exec.expr

Methods in org.apache.drill.exec.expr with parameters of type SchemaPath

Modifier and Type	Method and Description
LogicalExpression	CloneVisitor.visitSchemaPath(SchemaPath path, Void value)
Integer	HashVisitor.visitSchemaPath(SchemaPath path, Void value)

Constructor parameters in org.apache.drill.exec.expr with type arguments of type SchemaPath

Constructor and Description
StatisticsProvider(Map<SchemaPath,ColumnStatistics<?>> columnStatMap, long rowCount)

Uses of SchemaPath in org.apache.drill.exec.expr.fn.interpreter

Methods in org.apache.drill.exec.expr.fn.interpreter with parameters of type SchemaPath

Modifier and Type	Method and Description
ValueHolder	InterpreterEvaluator.EvalVisitor.visitSchemaPath(SchemaPath path, Integer value)

Uses of SchemaPath in org.apache.drill.exec.metastore.analyze

Methods in org.apache.drill.exec.metastore.analyze that return SchemaPath

Modifier and Type	Method and Description
SchemaPath	AnalyzeFileInfoProvider.getLocationField(ColumnNamesOptions columnNamesOptions)
SchemaPath	AnalyzeInfoProvider.getLocationField(ColumnNamesOptions columnNamesOptions) Provides schema path to field which will be used as a location for specific table data, for example, for file-based tables, it may be `fqn`.

Methods in org.apache.drill.exec.metastore.analyze that return types with arguments of type SchemaPath

Modifier and Type	Method and Description
List<SchemaPath>	AnalyzeFileInfoProvider.getProjectionFields(DrillTable table, MetadataType metadataLevel, ColumnNamesOptions columnNamesOptions)
List<SchemaPath>	AnalyzeInfoProvider.getProjectionFields(DrillTable table, MetadataType metadataLevel, ColumnNamesOptions columnNamesOptions) Returns list of fields required for ANALYZE.
List<SchemaPath>	AnalyzeParquetInfoProvider.getProjectionFields(DrillTable table, MetadataType metadataLevel, ColumnNamesOptions columnNamesOptions)
List<SchemaPath>	AnalyzeFileInfoProvider.getSegmentColumns(DrillTable table, ColumnNamesOptions columnNamesOptions)
List<SchemaPath>	AnalyzeInfoProvider.getSegmentColumns(DrillTable table, ColumnNamesOptions columnNamesOptions) Returns list of segment column names for specified DrillTable table.
List<SchemaPath>	MetadataAggregateContext.interestingColumns()
List<SchemaPath>	MetadataControllerContext.interestingColumns()
List<SchemaPath>	MetadataAggregateContext.metadataColumns()

Methods in org.apache.drill.exec.metastore.analyze with parameters of type SchemaPath

Modifier and Type	Method and Description
NamedExpression	AnalyzeFileInfoProvider.getParentLocationExpression(SchemaPath locationField)
NamedExpression	AnalyzeInfoProvider.getParentLocationExpression(SchemaPath locationField) Returns expression which may be used to determine parent location for specific table data, i.e.

Method parameters in org.apache.drill.exec.metastore.analyze with type arguments of type SchemaPath

Modifier and Type	Method and Description
MetadataInfoCollector	AnalyzeFileInfoProvider.getMetadataInfoCollector(BasicTablesRequests basicRequests, TableInfo tableInfo, FormatSelection selection, PlannerSettings settings, Supplier<org.apache.calcite.rel.core.TableScan> tableScanSupplier, List<SchemaPath> interestingColumns, MetadataType metadataLevel, int segmentColumnsCount)
MetadataInfoCollector	AnalyzeInfoProvider.getMetadataInfoCollector(BasicTablesRequests basicRequests, TableInfo tableInfo, FormatSelection selection, PlannerSettings settings, Supplier<org.apache.calcite.rel.core.TableScan> tableScanSupplier, List<SchemaPath> interestingColumns, MetadataType metadataLevel, int segmentColumnsCount) Returns MetadataInfoCollector instance for obtaining information about segments, files, etc.
MetadataAggregateContext.MetadataAggregateContextBuilder	MetadataAggregateContext.MetadataAggregateContextBuilder.interestingColumns(List<SchemaPath> interestingColumns)
MetadataControllerContext.MetadataControllerContextBuilder	MetadataControllerContext.MetadataControllerContextBuilder.interestingColumns(List<SchemaPath> interestingColumns)
MetadataAggregateContext.MetadataAggregateContextBuilder	MetadataAggregateContext.MetadataAggregateContextBuilder.metadataColumns(List<SchemaPath> metadataColumns)

Constructor parameters in org.apache.drill.exec.metastore.analyze with type arguments of type SchemaPath

Constructor and Description
FileMetadataInfoCollector(BasicTablesRequests basicRequests, TableInfo tableInfo, FormatSelection selection, PlannerSettings settings, Supplier<org.apache.calcite.rel.core.TableScan> tableScanSupplier, List<SchemaPath> interestingColumns, MetadataType metadataLevel, int segmentColumnsCount)

Uses of SchemaPath in org.apache.drill.exec.metastore.store

Methods in org.apache.drill.exec.metastore.store that return types with arguments of type SchemaPath

Modifier and Type	Method and Description
List<SchemaPath>	MetastoreFileTableMetadataProvider.getPartitionColumns()
List<SchemaPath>	SimpleFileTableMetadataProvider.getPartitionColumns()

Methods in org.apache.drill.exec.metastore.store with parameters of type SchemaPath

Modifier and Type	Method and Description
List<PartitionMetadata>	MetastoreFileTableMetadataProvider.getPartitionMetadata(SchemaPath columnName)
List<PartitionMetadata>	SimpleFileTableMetadataProvider.getPartitionMetadata(SchemaPath columnName)

Uses of SchemaPath in org.apache.drill.exec.physical.base

Fields in org.apache.drill.exec.physical.base with type parameters of type SchemaPath

Modifier and Type	Field and Description
static List<SchemaPath>	GroupScan.ALL_COLUMNS columns list in GroupScan : 1) empty_column is for skipAll query.
protected List<SchemaPath>	AbstractGroupScanWithMetadata.columns
protected List<SchemaPath>	AbstractGroupScanWithMetadata.partitionColumns

Methods in org.apache.drill.exec.physical.base that return SchemaPath

Modifier and Type	Method and Description
SchemaPath	AbstractDbGroupScan.getRowKeyPath()
SchemaPath	DbGroupScan.getRowKeyPath()

Methods in org.apache.drill.exec.physical.base that return types with arguments of type SchemaPath

Modifier and Type	Method and Description
List<SchemaPath>	AbstractGroupScan.getColumns()
List<SchemaPath>	AbstractGroupScanWithMetadata.getColumns()
List<SchemaPath>	DbGroupScan.getColumns()
List<SchemaPath>	GroupScan.getColumns() Returns a list of columns scanned by this group scan
List<SchemaPath>	IndexGroupScan.getColumns()
List<SchemaPath>	AbstractGroupScan.getPartitionColumns()
List<SchemaPath>	AbstractGroupScanWithMetadata.getPartitionColumns()
List<SchemaPath>	GroupScan.getPartitionColumns() Returns a list of columns that can be used for partition pruning

Methods in org.apache.drill.exec.physical.base with parameters of type SchemaPath

Modifier and Type	Method and Description
long	AbstractGroupScan.getColumnValueCount(SchemaPath column) By default, throw exception, since group scan does not have exact column value count.
long	AbstractGroupScanWithMetadata.getColumnValueCount(SchemaPath column) Return column value count for the specified column.
long	GroupScan.getColumnValueCount(SchemaPath column) Return the number of non-null value in the specified column.
<T> T	AbstractGroupScanWithMetadata.getPartitionValue(org.apache.hadoop.fs.Path path, SchemaPath column, Class<T> clazz)
TypeProtos.MajorType	AbstractGroupScanWithMetadata.getTypeForColumn(SchemaPath schemaPath)
static boolean	AbstractGroupScanWithMetadata.isImplicitOrPartCol(SchemaPath schemaPath, OptionManager optionManager)

Method parameters in org.apache.drill.exec.physical.base with type arguments of type SchemaPath

Modifier and Type	Method and Description
boolean	SchemalessScan.canPushdownProjects(List<SchemaPath> columns)
boolean	AbstractGroupScan.canPushdownProjects(List<SchemaPath> columns)
boolean	GroupScan.canPushdownProjects(List<SchemaPath> columns) GroupScan should check the list of columns, and see if it could support all the columns in the list.
GroupScan	SchemalessScan.clone(List<SchemaPath> columns)
GroupScan	AbstractGroupScan.clone(List<SchemaPath> columns)
GroupScan	GroupScan.clone(List<SchemaPath> columns) Returns a clone of GroupScan instance, except that the new GroupScan will use the provided list of columns .
<T extends Metadata> List<T>	AbstractGroupScanWithMetadata.GroupScanWithMetadataFilterer.filterAndGetMetadata(Set<SchemaPath> schemaPathsInExpr, Iterable<T> metadataList, FilterPredicate<?> filterPredicate, OptionManager optionManager) Produces filtering of specified metadata using specified filter expression and returns filtered metadata.
protected void	AbstractGroupScanWithMetadata.GroupScanWithMetadataFilterer.filterFileMetadata(OptionManager optionManager, FilterPredicate<?> filterPredicate, Set<SchemaPath> schemaPathsInExpr) Produces filtering of metadata at file level.
protected void	AbstractGroupScanWithMetadata.GroupScanWithMetadataFilterer.filterPartitionMetadata(OptionManager optionManager, FilterPredicate<?> filterPredicate, Set<SchemaPath> schemaPathsInExpr) Produces filtering of metadata at partition level.
protected void	AbstractGroupScanWithMetadata.GroupScanWithMetadataFilterer.filterSegmentMetadata(OptionManager optionManager, FilterPredicate<?> filterPredicate, Set<SchemaPath> schemaPathsInExpr) Produces filtering of metadata at segment level.
protected void	AbstractGroupScanWithMetadata.GroupScanWithMetadataFilterer.filterTableMetadata(FilterPredicate<?> filterPredicate, Set<SchemaPath> schemaPathsInExpr) Produces filtering of metadata at table level.
DbGroupScan	AbstractDbGroupScan.getRestrictedScan(List<SchemaPath> columns)
DbGroupScan	DbGroupScan.getRestrictedScan(List<SchemaPath> columns) If this DbGroupScan supports restricted scan, create a restricted scan from this DbGroupScan.
void	IndexGroupScan.setColumns(List<SchemaPath> columns)

Constructor parameters in org.apache.drill.exec.physical.base with type arguments of type SchemaPath

Constructor and Description
AbstractGroupScanWithMetadata(String userName, List<SchemaPath> columns, LogicalExpression filter)
SchemalessScan(String userName, org.apache.hadoop.fs.Path selectionRoot, List<SchemaPath> columns)

Uses of SchemaPath in org.apache.drill.exec.physical.config

Methods in org.apache.drill.exec.physical.config that return SchemaPath

Modifier and Type	Method and Description
SchemaPath	FlattenPOP.getColumn()
SchemaPath	UnnestPOP.getColumn()

Methods in org.apache.drill.exec.physical.config that return types with arguments of type SchemaPath

Modifier and Type	Method and Description
List<SchemaPath>	LateralJoinPOP.getExcludedColumns()

Constructors in org.apache.drill.exec.physical.config with parameters of type SchemaPath

Constructor and Description
FlattenPOP(PhysicalOperator child, SchemaPath column)
UnnestPOP(PhysicalOperator child, SchemaPath column, String implicitColumn)

Constructor parameters in org.apache.drill.exec.physical.config with type arguments of type SchemaPath

Constructor and Description
LateralJoinPOP(PhysicalOperator left, PhysicalOperator right, org.apache.calcite.rel.core.JoinRelType joinType, String implicitRIDColumn, List<SchemaPath> excludedColumns)

Uses of SchemaPath in org.apache.drill.exec.physical.impl

Methods in org.apache.drill.exec.physical.impl with parameters of type SchemaPath

Modifier and Type	Method and Description
TypedFieldId	ScanBatch.getValueVectorId(SchemaPath path)

Uses of SchemaPath in org.apache.drill.exec.physical.impl.aggregate

Methods in org.apache.drill.exec.physical.impl.aggregate with parameters of type SchemaPath

Modifier and Type	Method and Description
TypedFieldId	SpilledRecordBatch.getValueVectorId(SchemaPath path)

Uses of SchemaPath in org.apache.drill.exec.physical.impl.orderedpartitioner

Methods in org.apache.drill.exec.physical.impl.orderedpartitioner with parameters of type SchemaPath

Modifier and Type	Method and Description
void	OrderedPartitionProjector.setup(FragmentContext context, VectorAccessible incoming, RecordBatch outgoing, List<TransferPair> transfers, VectorContainer partitionVectors, int partitions, SchemaPath outputField)
void	OrderedPartitionProjectorTemplate.setup(FragmentContext context, VectorAccessible incoming, RecordBatch outgoing, List<TransferPair> transfers, VectorContainer partitionVectors, int partitions, SchemaPath outputField)

Uses of SchemaPath in org.apache.drill.exec.physical.impl.partitionsender

Methods in org.apache.drill.exec.physical.impl.partitionsender with parameters of type SchemaPath

Modifier and Type	Method and Description
TypedFieldId	PartitionerTemplate.OutgoingRecordBatch.getValueVectorId(SchemaPath path)

Uses of SchemaPath in org.apache.drill.exec.physical.impl.protocol

Methods in org.apache.drill.exec.physical.impl.protocol with parameters of type SchemaPath

Modifier and Type	Method and Description
TypedFieldId	BatchAccessor.getValueVectorId(SchemaPath path)
TypedFieldId	OperatorRecordBatch.getValueVectorId(SchemaPath path)
TypedFieldId	VectorContainerAccessor.getValueVectorId(SchemaPath path)

Uses of SchemaPath in org.apache.drill.exec.physical.impl.scan.project

Fields in org.apache.drill.exec.physical.impl.scan.project with type parameters of type SchemaPath

Modifier and Type	Field and Description
List<SchemaPath>	ScanSchemaOrchestrator.ScanSchemaOptions.projection
protected List<SchemaPath>	ScanLevelProjection.projectionList

Methods in org.apache.drill.exec.physical.impl.scan.project that return types with arguments of type SchemaPath

Modifier and Type	Method and Description
List<SchemaPath>	ScanLevelProjection.Builder.projectionList()
List<SchemaPath>	ScanLevelProjection.requestedCols() Return the set of columns from the SELECT list

Method parameters in org.apache.drill.exec.physical.impl.scan.project with type arguments of type SchemaPath

Modifier and Type	Method and Description
static ScanLevelProjection	ScanLevelProjection.build(List<SchemaPath> projectionList, List<ScanLevelProjection.ScanProjectionParser> parsers) Builder shortcut, primarily for tests.
static ScanLevelProjection	ScanLevelProjection.build(List<SchemaPath> projectionList, List<ScanLevelProjection.ScanProjectionParser> parsers, TupleMetadata outputSchema) Builder shortcut, primarily for tests.
void	ScanSchemaOrchestrator.ScanOrchestratorBuilder.projection(List<SchemaPath> projection)
ScanLevelProjection.Builder	ScanLevelProjection.Builder.projection(List<SchemaPath> projectionList) Specify the set of columns in the SELECT list.

Uses of SchemaPath in org.apache.drill.exec.physical.impl.scan.v3

Methods in org.apache.drill.exec.physical.impl.scan.v3 that return types with arguments of type SchemaPath

Modifier and Type	Method and Description
List<SchemaPath>	ScanLifecycleBuilder.projection()

Method parameters in org.apache.drill.exec.physical.impl.scan.v3 with type arguments of type SchemaPath

Modifier and Type	Method and Description
void	ScanLifecycleBuilder.projection(List<SchemaPath> projection)

Uses of SchemaPath in org.apache.drill.exec.physical.impl.scan.v3.schema

Method parameters in org.apache.drill.exec.physical.impl.scan.v3.schema with type arguments of type SchemaPath

Modifier and Type	Method and Description
static ScanProjectionParser.ProjectionParseResult	ScanProjectionParser.parse(Collection<SchemaPath> projList)
ScanSchemaConfigBuilder	ScanSchemaConfigBuilder.projection(List<SchemaPath> projectionList)

Uses of SchemaPath in org.apache.drill.exec.physical.impl.unorderedreceiver

Methods in org.apache.drill.exec.physical.impl.unorderedreceiver with parameters of type SchemaPath

Modifier and Type	Method and Description
TypedFieldId	UnorderedReceiverBatch.getValueVectorId(SchemaPath path)

Uses of SchemaPath in org.apache.drill.exec.physical.impl.validate

Methods in org.apache.drill.exec.physical.impl.validate with parameters of type SchemaPath

Modifier and Type	Method and Description
TypedFieldId	IteratorValidatorBatchIterator.getValueVectorId(SchemaPath path)

Uses of SchemaPath in org.apache.drill.exec.physical.impl.window

Methods in org.apache.drill.exec.physical.impl.window with parameters of type SchemaPath

Modifier and Type	Method and Description
TypedFieldId	WindowDataBatch.getValueVectorId(SchemaPath path)

Uses of SchemaPath in org.apache.drill.exec.physical.impl.xsort

Methods in org.apache.drill.exec.physical.impl.xsort with parameters of type SchemaPath

Modifier and Type	Method and Description
TypedFieldId	BatchGroup.getValueVectorId(SchemaPath path)

Uses of SchemaPath in org.apache.drill.exec.physical.resultSet.project

Method parameters in org.apache.drill.exec.physical.resultSet.project with type arguments of type SchemaPath

Modifier and Type	Method and Description
static RequestedTuple	Projections.parse(Collection<SchemaPath> projList) Parse a projection list.

Uses of SchemaPath in org.apache.drill.exec.planner

Methods in org.apache.drill.exec.planner with parameters of type SchemaPath

Modifier and Type	Method and Description
TypeProtos.MajorType	PartitionDescriptor.getVectorType(SchemaPath column, PlannerSettings plannerSettings) Method returns the Major type associated with the given column
TypeProtos.MajorType	FileSystemPartitionDescriptor.getVectorType(SchemaPath column, PlannerSettings plannerSettings)
TypeProtos.MajorType	ParquetPartitionDescriptor.getVectorType(SchemaPath column, PlannerSettings plannerSettings)

Uses of SchemaPath in org.apache.drill.exec.planner.common

Methods in org.apache.drill.exec.planner.common that return SchemaPath

Modifier and Type	Method and Description
SchemaPath	DrillStatsTable.ColumnStatistics_v1.getName()

Methods in org.apache.drill.exec.planner.common that return types with arguments of type SchemaPath

Modifier and Type	Method and Description
Set<SchemaPath>	DrillStatsTable.getColumns()
List<SchemaPath>	DrillRelOptUtil.ProjectPushInfo.getFields()

Methods in org.apache.drill.exec.planner.common with parameters of type SchemaPath

Modifier and Type	Method and Description
static List<StatisticsHolder<?>>	DrillStatsTable.getEstimatedColumnStats(DrillStatsTable statsProvider, SchemaPath fieldName) Returns list of StatisticsKind and statistics values obtained from specified DrillStatsTable for specified column.
Histogram	DrillStatsTable.getHistogram(SchemaPath column) Get the histogram of a given column.
Double	DrillStatsTable.getNdv(SchemaPath col) Get the approximate number of distinct values of given column.
Double	DrillStatsTable.getNNRowCount(SchemaPath col) Get non-null rowcount for the column If stats are not present for the given column, a null is returned.
void	DrillStatsTable.ColumnStatistics_v1.setName(SchemaPath name)

Constructor parameters in org.apache.drill.exec.planner.common with type arguments of type SchemaPath

Constructor and Description
DrillScanRelBase(org.apache.calcite.plan.RelOptCluster cluster, org.apache.calcite.plan.RelTraitSet traits, org.apache.calcite.plan.RelOptTable table, List<SchemaPath> columns)
ProjectPushInfo(List<SchemaPath> fields, Map<String,FieldsReWriterUtil.DesiredField> desiredFields)

Uses of SchemaPath in org.apache.drill.exec.planner.index

Methods in org.apache.drill.exec.planner.index that return SchemaPath

Modifier and Type	Method and Description
SchemaPath	FunctionalIndexInfo.getNewPath(SchemaPath path) getNewPath: for an original path, return new rename '$N' path, notice there could be multiple renamed paths if the there are multiple functional indexes refer original path.
SchemaPath	MapRDBFunctionalIndexInfo.getNewPath(SchemaPath path) getNewPath: for an original path, return new rename '$N' path, notice there could be multiple renamed paths if the there are multiple functional indexes refer original path.
SchemaPath	FunctionalIndexInfo.getNewPathFromExpr(LogicalExpression expr) return a plain field path if the incoming index expression 'expr' is replaced to be a plain field
SchemaPath	MapRDBFunctionalIndexInfo.getNewPathFromExpr(LogicalExpression expr) return a plain field path if the incoming index expression 'expr' is replaced to be a plain field

Methods in org.apache.drill.exec.planner.index that return types with arguments of type SchemaPath

Modifier and Type	Method and Description
Set<SchemaPath>	FunctionalIndexInfo.allNewSchemaPaths()
Set<SchemaPath>	MapRDBFunctionalIndexInfo.allNewSchemaPaths()
Set<SchemaPath>	FunctionalIndexInfo.allPathsInFunction()
Set<SchemaPath>	MapRDBFunctionalIndexInfo.allPathsInFunction()
Map<LogicalExpression,Set<SchemaPath>>	FunctionalIndexInfo.getPathsInFunctionExpr()
Map<LogicalExpression,Set<SchemaPath>>	MapRDBFunctionalIndexInfo.getPathsInFunctionExpr() Suppose the index key has functions (rather than plain columns): CAST(a as int), CAST(b as varchar(10)), then we want to maintain a mapping of the logical expression of that function to the schema path of the base column involved in the function.
List<SchemaPath>	IndexCallContext.getScanColumns()
List<SchemaPath>	IndexLogicalPlanCallContext.getScanColumns()
List<SchemaPath>	IndexPhysicalPlanCallContext.getScanColumns()
static List<SchemaPath>	IndexPlanUtils.rewriteFunctionColumn(List<SchemaPath> paths, FunctionalIndexInfo functionInfo, List<SchemaPath> addedPaths) For IndexGroupScan, if a column is only appeared in the should-be-renamed function, this column is to-be-replaced column, we replace that column(schemaPath) from 'a.b' to '$1' in the list of SchemaPath.

Methods in org.apache.drill.exec.planner.index with parameters of type SchemaPath

Modifier and Type	Method and Description
SchemaPath	FunctionalIndexInfo.getNewPath(SchemaPath path) getNewPath: for an original path, return new rename '$N' path, notice there could be multiple renamed paths if the there are multiple functional indexes refer original path.
SchemaPath	MapRDBFunctionalIndexInfo.getNewPath(SchemaPath path) getNewPath: for an original path, return new rename '$N' path, notice there could be multiple renamed paths if the there are multiple functional indexes refer original path.
boolean	AbstractIndexCollection.isColumnIndexed(SchemaPath path)
boolean	IndexCollection.isColumnIndexed(SchemaPath path) Check if the field name is the leading key of any of the indexes in this collection
boolean	DrillIndexDefinition.pathExactIn(SchemaPath path, Collection<LogicalExpression> exprs)
static boolean	IndexPlanUtils.pathOnlyInIndexedFunction(SchemaPath path)
Boolean	PathInExpr.visitSchemaPath(SchemaPath path, Void value)
org.apache.calcite.rex.RexNode	ExprToRex.visitSchemaPath(SchemaPath path, Void value)

Method parameters in org.apache.drill.exec.planner.index with type arguments of type SchemaPath

Modifier and Type	Method and Description
static org.apache.calcite.rel.type.RelDataType	FunctionalIndexHelper.rewriteFunctionalRowType(org.apache.calcite.rel.RelNode origScan, IndexCallContext indexContext, FunctionalIndexInfo functionInfo, Collection<SchemaPath> addedPaths) if a field in rowType serves only the to-be-replaced column(s), we should replace it with new name "$1", otherwise we should keep this dataTypeField and add a new one for "$1"
static List<SchemaPath>	IndexPlanUtils.rewriteFunctionColumn(List<SchemaPath> paths, FunctionalIndexInfo functionInfo, List<SchemaPath> addedPaths) For IndexGroupScan, if a column is only appeared in the should-be-renamed function, this column is to-be-replaced column, we replace that column(schemaPath) from 'a.b' to '$1' in the list of SchemaPath.
static List<SchemaPath>	IndexPlanUtils.rewriteFunctionColumn(List<SchemaPath> paths, FunctionalIndexInfo functionInfo, List<SchemaPath> addedPaths) For IndexGroupScan, if a column is only appeared in the should-be-renamed function, this column is to-be-replaced column, we replace that column(schemaPath) from 'a.b' to '$1' in the list of SchemaPath.

Constructor parameters in org.apache.drill.exec.planner.index with type arguments of type SchemaPath

Constructor and Description
PathInExpr(Map<LogicalExpression,Set<SchemaPath>> pathsInExpr)

Uses of SchemaPath in org.apache.drill.exec.planner.index.generators

Method parameters in org.apache.drill.exec.planner.index.generators with type arguments of type SchemaPath

Modifier and Type	Method and Description
protected boolean	AbstractIndexPlanGenerator.checkRowKey(List<SchemaPath> columns)

Uses of SchemaPath in org.apache.drill.exec.planner.logical

Methods in org.apache.drill.exec.planner.logical that return types with arguments of type SchemaPath

Modifier and Type	Method and Description
List<SchemaPath>	DrillScanRel.getColumns()
static List<SchemaPath>	DrillScanRel.getProjectedColumns(org.apache.calcite.plan.RelOptTable table, boolean isSelectStar)

Methods in org.apache.drill.exec.planner.logical with parameters of type SchemaPath

Modifier and Type	Method and Description
void	ScanFieldDeterminer.FieldList.addProjected(SchemaPath path)
void	ScanFieldDeterminer.FieldList.addReferenced(SchemaPath path)

Method parameters in org.apache.drill.exec.planner.logical with type arguments of type SchemaPath

Modifier and Type	Method and Description
void	ScanFieldDeterminer.FieldList.addProjected(Collection<SchemaPath> paths)
void	ScanFieldDeterminer.FieldList.addReferenced(Collection<SchemaPath> paths)

Constructor parameters in org.apache.drill.exec.planner.logical with type arguments of type SchemaPath

Constructor and Description
DrillScanRel(org.apache.calcite.plan.RelOptCluster cluster, org.apache.calcite.plan.RelTraitSet traits, org.apache.calcite.plan.RelOptTable table, GroupScan groupScan, org.apache.calcite.rel.type.RelDataType rowType, List<SchemaPath> columns) Creates a DrillScanRel for a particular GroupScan
DrillScanRel(org.apache.calcite.plan.RelOptCluster cluster, org.apache.calcite.plan.RelTraitSet traits, org.apache.calcite.plan.RelOptTable table, GroupScan groupScan, org.apache.calcite.rel.type.RelDataType rowType, List<SchemaPath> columns, boolean partitionFilterPushdown) Creates a DrillScanRel for a particular GroupScan
DrillScanRel(org.apache.calcite.plan.RelOptCluster cluster, org.apache.calcite.plan.RelTraitSet traits, org.apache.calcite.plan.RelOptTable table, org.apache.calcite.rel.type.RelDataType rowType, List<SchemaPath> columns)
DrillScanRel(org.apache.calcite.plan.RelOptCluster cluster, org.apache.calcite.plan.RelTraitSet traits, org.apache.calcite.plan.RelOptTable table, org.apache.calcite.rel.type.RelDataType rowType, List<SchemaPath> columns, boolean partitionFilterPushdown)

Uses of SchemaPath in org.apache.drill.exec.planner.sql

Methods in org.apache.drill.exec.planner.sql with parameters of type SchemaPath

Modifier and Type	Method and Description
TypeProtos.MajorType	HivePartitionDescriptor.getVectorType(SchemaPath column, PlannerSettings plannerSettings)

Uses of SchemaPath in org.apache.drill.exec.planner.sql.parser

Methods in org.apache.drill.exec.planner.sql.parser that return types with arguments of type SchemaPath

Modifier and Type	Method and Description
List<SchemaPath>	SqlMetastoreAnalyzeTable.getFieldNames()

Uses of SchemaPath in org.apache.drill.exec.record

Methods in org.apache.drill.exec.record that return types with arguments of type SchemaPath

Modifier and Type	Method and Description
static List<SchemaPath>	SchemaUtil.getSchemaPaths(TupleMetadata schema) Returns list of SchemaPath for fields taken from specified schema.

Methods in org.apache.drill.exec.record with parameters of type SchemaPath

Modifier and Type	Method and Description
TypedFieldId	HyperVectorWrapper.getFieldIdIfMatches(int id, SchemaPath expectedPath)
TypedFieldId	SimpleVectorWrapper.getFieldIdIfMatches(int id, SchemaPath expectedPath)
TypedFieldId	VectorWrapper.getFieldIdIfMatches(int id, SchemaPath expectedPath) Traverse the object graph and determine whether the provided SchemaPath matches data within the Wrapper.
TypedFieldId	RecordBatch.getValueVectorId(SchemaPath path) Gets the value vector type and ID for the given schema path.
TypedFieldId	RecordIterator.getValueVectorId(SchemaPath path)
TypedFieldId	SchemalessBatch.getValueVectorId(SchemaPath path)
TypedFieldId	SimpleRecordBatch.getValueVectorId(SchemaPath path)
TypedFieldId	VectorAccessible.getValueVectorId(SchemaPath path) Get the value vector type and id for the given schema path.
TypedFieldId	RecordBatchLoader.getValueVectorId(SchemaPath path)
TypedFieldId	AbstractRecordBatch.getValueVectorId(SchemaPath path)
TypedFieldId	VectorContainer.getValueVectorId(SchemaPath path)

Uses of SchemaPath in org.apache.drill.exec.store

Fields in org.apache.drill.exec.store with type parameters of type SchemaPath

Modifier and Type	Field and Description
protected static List<SchemaPath>	AbstractRecordReader.DEFAULT_TEXT_COLS_TO_READ

Methods in org.apache.drill.exec.store that return types with arguments of type SchemaPath

Modifier and Type	Method and Description
protected Collection<SchemaPath>	AbstractRecordReader.getColumns()
protected List<SchemaPath>	AbstractRecordReader.getDefaultColumnsToRead()
List<SchemaPath>	ColumnExplorer.getTableColumns()
protected Collection<SchemaPath>	AbstractRecordReader.transformColumns(Collection<SchemaPath> projected)

Methods in org.apache.drill.exec.store with parameters of type SchemaPath

Modifier and Type	Method and Description
static boolean	ColumnExplorer.isPartitionColumn(OptionManager optionManager, SchemaPath column) Checks if given column is partition or not.

Method parameters in org.apache.drill.exec.store with type arguments of type SchemaPath

Modifier and Type	Method and Description
AbstractGroupScan	AbstractStoragePlugin.getPhysicalScan(String userName, JSONOptions selection, List<SchemaPath> columns)
AbstractGroupScan	StoragePlugin.getPhysicalScan(String userName, JSONOptions selection, List<SchemaPath> columns) Get the physical scan operator for the particular GroupScan (read) node.
AbstractGroupScan	AbstractStoragePlugin.getPhysicalScan(String userName, JSONOptions selection, List<SchemaPath> columns, SessionOptionManager options)
AbstractGroupScan	StoragePlugin.getPhysicalScan(String userName, JSONOptions selection, List<SchemaPath> columns, SessionOptionManager options) Get the physical scan operator for the particular GroupScan (read) node.
AbstractGroupScan	AbstractStoragePlugin.getPhysicalScan(String userName, JSONOptions selection, List<SchemaPath> columns, SessionOptionManager options, MetadataProviderManager metadataProviderManager)
AbstractGroupScan	StoragePlugin.getPhysicalScan(String userName, JSONOptions selection, List<SchemaPath> columns, SessionOptionManager options, MetadataProviderManager providerManager) Get the physical scan operator for the particular GroupScan (read) node.
protected void	AbstractRecordReader.setColumns(Collection<SchemaPath> projected)
protected Collection<SchemaPath>	AbstractRecordReader.transformColumns(Collection<SchemaPath> projected)

Constructor parameters in org.apache.drill.exec.store with type arguments of type SchemaPath

Constructor and Description
ColumnExplorer(OptionManager optionManager, List<SchemaPath> columns) Helper class that encapsulates logic for sorting out columns between actual table columns, partition columns and implicit file columns.

Uses of SchemaPath in org.apache.drill.exec.store.bson

Constructor parameters in org.apache.drill.exec.store.bson with type arguments of type SchemaPath

Constructor and Description
BsonRecordReader(DrillBuf managedBuf, List<SchemaPath> columns, boolean readNumbersAsDouble)

Uses of SchemaPath in org.apache.drill.exec.store.dfs

Method parameters in org.apache.drill.exec.store.dfs with type arguments of type SchemaPath

Modifier and Type	Method and Description
AbstractGroupScan	FormatPlugin.getGroupScan(String userName, FileSelection selection, List<SchemaPath> columns)
default AbstractGroupScan	FormatPlugin.getGroupScan(String userName, FileSelection selection, List<SchemaPath> columns, MetadataProviderManager metadataProviderManager)
default AbstractGroupScan	FormatPlugin.getGroupScan(String userName, FileSelection selection, List<SchemaPath> columns, OptionManager options)
default AbstractGroupScan	FormatPlugin.getGroupScan(String userName, FileSelection selection, List<SchemaPath> columns, OptionManager options, MetadataProviderManager metadataProvider)
AbstractGroupScan	FileSystemPlugin.getPhysicalScan(String userName, JSONOptions selection, List<SchemaPath> columns)
AbstractGroupScan	FileSystemPlugin.getPhysicalScan(String userName, JSONOptions selection, List<SchemaPath> columns, SessionOptionManager options, MetadataProviderManager metadataProviderManager)

Uses of SchemaPath in org.apache.drill.exec.store.dfs.easy

Methods in org.apache.drill.exec.store.dfs.easy that return types with arguments of type SchemaPath

Modifier and Type	Method and Description
List<SchemaPath>	EasySubScan.getColumns()

Method parameters in org.apache.drill.exec.store.dfs.easy with type arguments of type SchemaPath

Modifier and Type	Method and Description
boolean	EasyGroupScan.canPushdownProjects(List<SchemaPath> columns)
GroupScan	EasyGroupScan.clone(List<SchemaPath> columns)
AbstractGroupScan	EasyFormatPlugin.getGroupScan(String userName, FileSelection selection, List<SchemaPath> columns)
AbstractGroupScan	EasyFormatPlugin.getGroupScan(String userName, FileSelection selection, List<SchemaPath> columns, MetadataProviderManager metadataProviderManager)
RecordReader	EasyFormatPlugin.getRecordReader(FragmentContext context, DrillFileSystem dfs, FileWork fileWork, List<SchemaPath> columns, String userName) Return a record reader for the specific file format, when using the original ScanBatch scanner.

Constructor parameters in org.apache.drill.exec.store.dfs.easy with type arguments of type SchemaPath

Constructor and Description
EasyGroupScan(String userName, FileSelection selection, EasyFormatPlugin<?> formatPlugin, List<SchemaPath> columns, org.apache.hadoop.fs.Path selectionRoot, int minWidth, MetadataProviderManager metadataProvider)
EasyGroupScan(String userName, FileSelection selection, EasyFormatPlugin<?> formatPlugin, List<SchemaPath> columns, org.apache.hadoop.fs.Path selectionRoot, MetadataProviderManager metadataProviderManager)
EasyGroupScan(String userName, List<org.apache.hadoop.fs.Path> files, StoragePluginConfig storageConfig, FormatPluginConfig formatConfig, StoragePluginRegistry engineRegistry, List<SchemaPath> columns, org.apache.hadoop.fs.Path selectionRoot, TupleMetadata schema, int limit)
EasySubScan(String userName, List<CompleteFileWork.FileWorkImpl> files, EasyFormatPlugin<?> plugin, List<SchemaPath> columns, org.apache.hadoop.fs.Path selectionRoot, int partitionDepth, TupleMetadata schema, int limit)
EasySubScan(String userName, List<CompleteFileWork.FileWorkImpl> files, StoragePluginConfig storageConfig, FormatPluginConfig formatConfig, StoragePluginRegistry engineRegistry, List<SchemaPath> columns, org.apache.hadoop.fs.Path selectionRoot, int partitionDepth, TupleMetadata schema, int limit)

Uses of SchemaPath in org.apache.drill.exec.store.direct

Methods in org.apache.drill.exec.store.direct that return types with arguments of type SchemaPath

Modifier and Type	Method and Description
List<SchemaPath>	DirectGroupScan.getColumns()

Method parameters in org.apache.drill.exec.store.direct with type arguments of type SchemaPath

Modifier and Type	Method and Description
GroupScan	DirectGroupScan.clone(List<SchemaPath> columns)
GroupScan	MetadataDirectGroupScan.clone(List<SchemaPath> columns)

Uses of SchemaPath in org.apache.drill.exec.store.druid

Methods in org.apache.drill.exec.store.druid that return SchemaPath

Modifier and Type	Method and Description
SchemaPath	DruidCompareFunctionProcessor.getPath()

Methods in org.apache.drill.exec.store.druid that return types with arguments of type SchemaPath

Modifier and Type	Method and Description
List<SchemaPath>	DruidGroupScan.getColumns()
List<SchemaPath>	DruidSubScan.getColumns()
protected Collection<SchemaPath>	DruidRecordReader.transformColumns(Collection<SchemaPath> projectedColumns)

Methods in org.apache.drill.exec.store.druid with parameters of type SchemaPath

Modifier and Type	Method and Description
Boolean	DruidCompareFunctionProcessor.visitSchemaPath(SchemaPath path, LogicalExpression valueArg)

Method parameters in org.apache.drill.exec.store.druid with type arguments of type SchemaPath

Modifier and Type	Method and Description
boolean	DruidGroupScan.canPushdownProjects(List<SchemaPath> columns)
GroupScan	DruidGroupScan.clone(List<SchemaPath> columns)
protected Collection<SchemaPath>	DruidRecordReader.transformColumns(Collection<SchemaPath> projectedColumns)

Constructor parameters in org.apache.drill.exec.store.druid with type arguments of type SchemaPath

Constructor and Description
DruidGroupScan(String userName, DruidScanSpec scanSpec, DruidStoragePluginConfig storagePluginConfig, List<SchemaPath> columns, int maxRecordsToRead, StoragePluginRegistry pluginRegistry)
DruidGroupScan(String userName, DruidStoragePlugin storagePlugin, DruidScanSpec scanSpec, List<SchemaPath> columns, int maxRecordsToRead)
DruidRecordReader(DruidSubScan.DruidSubScanSpec subScanSpec, List<SchemaPath> projectedColumns, int maxRecordsToRead, FragmentContext context, DruidStoragePlugin plugin)
DruidSubScan(StoragePluginRegistry registry, String userName, StoragePluginConfig config, LinkedList<DruidSubScan.DruidSubScanSpec> datasourceScanSpecList, List<SchemaPath> columns, int maxRecordsToRead)
DruidSubScan(String userName, DruidStoragePlugin plugin, List<DruidSubScan.DruidSubScanSpec> dataSourceInfoList, List<SchemaPath> columns, int maxRecordsToRead)

Uses of SchemaPath in org.apache.drill.exec.store.easy.json

Methods in org.apache.drill.exec.store.easy.json that return types with arguments of type SchemaPath

Modifier and Type	Method and Description
protected List<SchemaPath>	JSONRecordReader.getDefaultColumnsToRead()

Method parameters in org.apache.drill.exec.store.easy.json with type arguments of type SchemaPath

Modifier and Type	Method and Description
RecordReader	JSONFormatPlugin.getRecordReader(FragmentContext context, DrillFileSystem dfs, FileWork fileWork, List<SchemaPath> columns, String userName)

Constructor parameters in org.apache.drill.exec.store.easy.json with type arguments of type SchemaPath

Constructor and Description
JSONRecordReader(FragmentContext fragmentContext, com.fasterxml.jackson.databind.JsonNode embeddedContent, DrillFileSystem fileSystem, List<SchemaPath> columns) Create a new JSON Record Reader that uses a in memory materialized JSON stream.
JSONRecordReader(FragmentContext fragmentContext, List<SchemaPath> columns) Create a JSON Record Reader that uses an InputStream directly
JSONRecordReader(FragmentContext fragmentContext, org.apache.hadoop.fs.Path inputPath, DrillFileSystem fileSystem, List<SchemaPath> columns) Create a JSON Record Reader that uses a file based input stream.

Uses of SchemaPath in org.apache.drill.exec.store.easy.text

Method parameters in org.apache.drill.exec.store.easy.text with type arguments of type SchemaPath

Modifier and Type	Method and Description
AbstractGroupScan	TextFormatPlugin.getGroupScan(String userName, FileSelection selection, List<SchemaPath> columns, MetadataProviderManager metadataProviderManager)
AbstractGroupScan	TextFormatPlugin.getGroupScan(String userName, FileSelection selection, List<SchemaPath> columns, OptionManager options, MetadataProviderManager metadataProviderManager)

Uses of SchemaPath in org.apache.drill.exec.store.enumerable

Methods in org.apache.drill.exec.store.enumerable that return types with arguments of type SchemaPath

Modifier and Type	Method and Description
List<SchemaPath>	EnumerableGroupScan.getColumns()
List<SchemaPath>	EnumerableSubScan.getColumns()

Constructor parameters in org.apache.drill.exec.store.enumerable with type arguments of type SchemaPath

Constructor and Description
EnumerableGroupScan(String code, List<SchemaPath> columns, Map<String,Integer> fieldsMap, double rows, TupleMetadata schema, String schemaPath, ColumnConverterFactoryProvider converterFactoryProvider)
EnumerableRecordReader(List<SchemaPath> columns, Map<String,Integer> fieldsMap, String code, String schemaPath, ColumnConverterFactoryProvider factoryProvider)
EnumerableSubScan(String code, List<SchemaPath> columns, Map<String,Integer> fieldsMap, TupleMetadata schema, String schemaPath, ColumnConverterFactoryProvider converterFactoryProvider)

Uses of SchemaPath in org.apache.drill.exec.store.hbase

Fields in org.apache.drill.exec.store.hbase declared as SchemaPath

Modifier and Type	Field and Description
static SchemaPath	DrillHBaseConstants.ROW_KEY_PATH

Methods in org.apache.drill.exec.store.hbase that return SchemaPath

Modifier and Type	Method and Description
SchemaPath	CompareFunctionsProcessor.getPath()

Methods in org.apache.drill.exec.store.hbase that return types with arguments of type SchemaPath

Modifier and Type	Method and Description
List<SchemaPath>	HBaseGroupScan.getColumns()
List<SchemaPath>	HBaseSubScan.getColumns()
protected Collection<SchemaPath>	HBaseRecordReader.transformColumns(Collection<SchemaPath> columns) Provides the projected columns information to the Hbase Scan instance.

Methods in org.apache.drill.exec.store.hbase with parameters of type SchemaPath

Modifier and Type	Method and Description
protected void	CompareFunctionsProcessor.setPath(SchemaPath path)
Boolean	CompareFunctionsProcessor.visitSchemaPath(SchemaPath path, LogicalExpression valueArg)

Method parameters in org.apache.drill.exec.store.hbase with type arguments of type SchemaPath

Modifier and Type	Method and Description
boolean	HBaseGroupScan.canPushdownProjects(List<SchemaPath> columns)
GroupScan	HBaseGroupScan.clone(List<SchemaPath> columns)
protected Collection<SchemaPath>	HBaseRecordReader.transformColumns(Collection<SchemaPath> columns) Provides the projected columns information to the Hbase Scan instance.
static void	HBaseUtils.verifyColumns(List<SchemaPath> columns, org.apache.hadoop.hbase.HTableDescriptor hTableDesc) Verify the presence of a column family in the schema path of the hbase table or whether the schema path is the row key column.

Constructor parameters in org.apache.drill.exec.store.hbase with type arguments of type SchemaPath

Constructor and Description
HBaseGroupScan(String userName, HBaseScanSpec hbaseScanSpec, HBaseStoragePluginConfig storagePluginConfig, List<SchemaPath> columns, StoragePluginRegistry pluginRegistry)
HBaseGroupScan(String userName, HBaseStoragePlugin storagePlugin, HBaseScanSpec scanSpec, List<SchemaPath> columns)
HBaseRecordReader(org.apache.hadoop.hbase.client.Connection connection, HBaseSubScan.HBaseSubScanSpec subScanSpec, List<SchemaPath> projectedColumns)
HBaseSubScan(StoragePluginRegistry registry, String userName, HBaseStoragePluginConfig hbaseStoragePluginConfig, LinkedList<HBaseSubScan.HBaseSubScanSpec> regionScanSpecList, List<SchemaPath> columns)
HBaseSubScan(String userName, HBaseStoragePlugin hbaseStoragePlugin, List<HBaseSubScan.HBaseSubScanSpec> regionInfoList, List<SchemaPath> columns)

Uses of SchemaPath in org.apache.drill.exec.store.hive

Fields in org.apache.drill.exec.store.hive with type parameters of type SchemaPath

Modifier and Type	Field and Description
protected List<SchemaPath>	HiveScan.columns

Methods in org.apache.drill.exec.store.hive that return types with arguments of type SchemaPath

Modifier and Type	Method and Description
List<SchemaPath>	HiveScan.getColumns()
List<SchemaPath>	HiveSubScan.getColumns()

Method parameters in org.apache.drill.exec.store.hive with type arguments of type SchemaPath

Modifier and Type	Method and Description
boolean	HiveScan.canPushdownProjects(List<SchemaPath> columns)
GroupScan	HiveDrillNativeParquetScan.clone(List<SchemaPath> columns)
GroupScan	HiveScan.clone(List<SchemaPath> columns)
AbstractParquetRowGroupScan	HiveDrillNativeParquetRowGroupScan.copy(List<SchemaPath> columns)
HiveScan	HiveStoragePlugin.getPhysicalScan(String userName, JSONOptions selection, List<SchemaPath> columns)
HiveScan	HiveStoragePlugin.getPhysicalScan(String userName, JSONOptions selection, List<SchemaPath> columns, SessionOptionManager options)

Constructor parameters in org.apache.drill.exec.store.hive with type arguments of type SchemaPath

Constructor and Description
HiveDrillNativeParquetRowGroupScan(StoragePluginRegistry registry, String userName, HiveStoragePluginConfig hiveStoragePluginConfig, List<RowGroupReadEntry> rowGroupReadEntries, List<SchemaPath> columns, HivePartitionHolder hivePartitionHolder, Map<String,String> confProperties, ParquetReaderConfig readerConfig, LogicalExpression filter, TupleMetadata schema)
HiveDrillNativeParquetRowGroupScan(String userName, HiveStoragePlugin hiveStoragePlugin, List<RowGroupReadEntry> rowGroupReadEntries, List<SchemaPath> columns, HivePartitionHolder hivePartitionHolder, Map<String,String> confProperties, ParquetReaderConfig readerConfig, LogicalExpression filter, TupleMetadata schema)
HiveDrillNativeParquetScan(StoragePluginRegistry engineRegistry, String userName, HiveStoragePluginConfig hiveStoragePluginConfig, List<SchemaPath> columns, List<ReadEntryWithPath> entries, HivePartitionHolder hivePartitionHolder, Map<String,String> confProperties, ParquetReaderConfig readerConfig, LogicalExpression filter, TupleMetadata schema)
HiveDrillNativeParquetScan(String userName, List<SchemaPath> columns, HiveStoragePlugin hiveStoragePlugin, List<HiveMetadataProvider.LogicalInputSplit> logicalInputSplits, Map<String,String> confProperties, ParquetReaderConfig readerConfig)
HiveDrillNativeParquetScan(String userName, List<SchemaPath> columns, HiveStoragePlugin hiveStoragePlugin, List<HiveMetadataProvider.LogicalInputSplit> logicalInputSplits, Map<String,String> confProperties, ParquetReaderConfig readerConfig, LogicalExpression filter)
HiveScan(String userName, HiveReadEntry hiveReadEntry, HiveStoragePluginConfig hiveStoragePluginConfig, List<SchemaPath> columns, Map<String,String> confProperties, StoragePluginRegistry pluginRegistry)
HiveScan(String userName, HiveReadEntry hiveReadEntry, HiveStoragePlugin hiveStoragePlugin, List<SchemaPath> columns, HiveMetadataProvider metadataProvider, Map<String,String> confProperties)
HiveSubScan(StoragePluginRegistry registry, String userName, List<List<String>> splits, HiveReadEntry hiveReadEntry, List<String> splitClasses, List<SchemaPath> columns, HiveStoragePluginConfig hiveStoragePluginConfig, Map<String,String> confProperties)
HiveSubScan(String userName, List<List<String>> splits, HiveReadEntry hiveReadEntry, List<String> splitClasses, List<SchemaPath> columns, HiveStoragePlugin hiveStoragePlugin, Map<String,String> confProperties)

Uses of SchemaPath in org.apache.drill.exec.store.hive.readers

Constructor parameters in org.apache.drill.exec.store.hive.readers with type arguments of type SchemaPath

Constructor and Description
HiveDefaultRecordReader(HiveTableWithColumnCache table, HivePartition partition, Collection<org.apache.hadoop.mapred.InputSplit> inputSplits, List<SchemaPath> projectedColumns, FragmentContext context, org.apache.hadoop.hive.conf.HiveConf hiveConf, org.apache.hadoop.security.UserGroupInformation proxyUgi) Readers constructor called by initializer.
HiveTextRecordReader(HiveTableWithColumnCache table, HivePartition partition, Collection<org.apache.hadoop.mapred.InputSplit> inputSplits, List<SchemaPath> projectedColumns, FragmentContext context, org.apache.hadoop.hive.conf.HiveConf hiveConf, org.apache.hadoop.security.UserGroupInformation proxyUgi) Constructor matching super.

Uses of SchemaPath in org.apache.drill.exec.store.http

Methods in org.apache.drill.exec.store.http that return types with arguments of type SchemaPath

Modifier and Type	Method and Description
List<SchemaPath>	HttpGroupScan.columns()
List<SchemaPath>	HttpSubScan.columns()

Method parameters in org.apache.drill.exec.store.http with type arguments of type SchemaPath

Modifier and Type	Method and Description
boolean	HttpGroupScan.canPushdownProjects(List<SchemaPath> columns)
GroupScan	HttpGroupScan.clone(List<SchemaPath> columns)

Constructor parameters in org.apache.drill.exec.store.http with type arguments of type SchemaPath

Constructor and Description
HttpGroupScan(HttpGroupScan that, List<SchemaPath> columns) Applies columns.
HttpGroupScan(List<SchemaPath> columns, HttpScanSpec httpScanSpec, Map<String,String> filters, double selectivity, int maxRecords) Deserialize a group scan.
HttpSubScan(HttpScanSpec tableSpec, List<SchemaPath> columns, Map<String,String> filters, int maxRecords)

Uses of SchemaPath in org.apache.drill.exec.store.iceberg

Methods in org.apache.drill.exec.store.iceberg that return types with arguments of type SchemaPath

Modifier and Type	Method and Description
List<SchemaPath>	IcebergGroupScan.getColumns()
List<SchemaPath>	IcebergSubScan.getColumns()

Methods in org.apache.drill.exec.store.iceberg with parameters of type SchemaPath

Modifier and Type	Method and Description
static String	IcebergGroupScan.getPath(SchemaPath schemaPath)

Method parameters in org.apache.drill.exec.store.iceberg with type arguments of type SchemaPath

Modifier and Type	Method and Description
IcebergGroupScan	IcebergGroupScan.clone(List<SchemaPath> columns)
IcebergGroupScan.IcebergGroupScanBuilder	IcebergGroupScan.IcebergGroupScanBuilder.columns(List<SchemaPath> columns)
IcebergSubScan.IcebergSubScanBuilder	IcebergSubScan.IcebergSubScanBuilder.columns(List<SchemaPath> columns)
static org.apache.iceberg.TableScan	IcebergGroupScan.projectColumns(org.apache.iceberg.TableScan tableScan, List<SchemaPath> columns)

Constructor parameters in org.apache.drill.exec.store.iceberg with type arguments of type SchemaPath

Constructor and Description
IcebergGroupScan(String userName, StoragePluginConfig storageConfig, FormatPluginConfig formatConfig, List<SchemaPath> columns, TupleMetadata schema, String path, LogicalExpression condition, Integer maxRecords, StoragePluginRegistry pluginRegistry)
IcebergSubScan(String userName, StoragePluginConfig storageConfig, FormatPluginConfig formatConfig, List<SchemaPath> columns, String path, List<IcebergWork> workList, TupleMetadata schema, LogicalExpression condition, Integer maxRecords, StoragePluginRegistry pluginRegistry)

Uses of SchemaPath in org.apache.drill.exec.store.iceberg.format

Method parameters in org.apache.drill.exec.store.iceberg.format with type arguments of type SchemaPath

Modifier and Type	Method and Description
AbstractGroupScan	IcebergFormatPlugin.getGroupScan(String userName, FileSelection selection, List<SchemaPath> columns)
AbstractGroupScan	IcebergFormatPlugin.getGroupScan(String userName, FileSelection selection, List<SchemaPath> columns, MetadataProviderManager metadataProviderManager)

Uses of SchemaPath in org.apache.drill.exec.store.ischema

Methods in org.apache.drill.exec.store.ischema that return types with arguments of type SchemaPath

Modifier and Type	Method and Description
List<SchemaPath>	InfoSchemaGroupScan.getColumns()

Methods in org.apache.drill.exec.store.ischema with parameters of type SchemaPath

Modifier and Type	Method and Description
InfoSchemaFilter.ExprNode	InfoSchemaFilterBuilder.visitSchemaPath(SchemaPath path, Void value)

Method parameters in org.apache.drill.exec.store.ischema with type arguments of type SchemaPath

Modifier and Type	Method and Description
GroupScan	InfoSchemaGroupScan.clone(List<SchemaPath> columns)
InfoSchemaGroupScan	InfoSchemaStoragePlugin.getPhysicalScan(String userName, JSONOptions selection, List<SchemaPath> columns)

Uses of SchemaPath in org.apache.drill.exec.store.jdbc

Methods in org.apache.drill.exec.store.jdbc that return types with arguments of type SchemaPath

Modifier and Type	Method and Description
List<SchemaPath>	JdbcGroupScan.getColumns()
List<SchemaPath>	JdbcSubScan.getColumns()

Constructor parameters in org.apache.drill.exec.store.jdbc with type arguments of type SchemaPath

Constructor and Description
JdbcBatchReader(DataSource source, String sql, List<SchemaPath> columns)
JdbcGroupScan(String sql, List<SchemaPath> columns, StoragePluginConfig config, double rows, StoragePluginRegistry plugins)
JdbcSubScan(String sql, List<SchemaPath> columns, StoragePluginConfig config, StoragePluginRegistry plugins)

Uses of SchemaPath in org.apache.drill.exec.store.kafka

Methods in org.apache.drill.exec.store.kafka that return types with arguments of type SchemaPath

Modifier and Type	Method and Description
List<SchemaPath>	KafkaGroupScan.getColumns()
List<SchemaPath>	KafkaSubScan.getColumns()

Method parameters in org.apache.drill.exec.store.kafka with type arguments of type SchemaPath

Modifier and Type	Method and Description
boolean	KafkaGroupScan.canPushdownProjects(List<SchemaPath> columns)
GroupScan	KafkaGroupScan.clone(List<SchemaPath> columns)

Constructor parameters in org.apache.drill.exec.store.kafka with type arguments of type SchemaPath

Constructor and Description
KafkaGroupScan(KafkaStoragePlugin kafkaStoragePlugin, KafkaScanSpec kafkaScanSpec, List<SchemaPath> columns)
KafkaGroupScan(String userName, KafkaStoragePluginConfig kafkaStoragePluginConfig, List<SchemaPath> columns, KafkaScanSpec scanSpec, StoragePluginRegistry pluginRegistry)
KafkaGroupScan(String userName, KafkaStoragePlugin kafkaStoragePlugin, List<SchemaPath> columns, KafkaScanSpec kafkaScanSpec)
KafkaSubScan(StoragePluginRegistry registry, String userName, KafkaStoragePluginConfig kafkaStoragePluginConfig, List<SchemaPath> columns, LinkedList<KafkaPartitionScanSpec> partitionSubScanSpecList)
KafkaSubScan(String userName, KafkaStoragePlugin kafkaStoragePlugin, List<SchemaPath> columns, List<KafkaPartitionScanSpec> partitionSubScanSpecList)

Uses of SchemaPath in org.apache.drill.exec.store.kudu

Methods in org.apache.drill.exec.store.kudu that return types with arguments of type SchemaPath

Modifier and Type	Method and Description
List<SchemaPath>	KuduSubScan.getColumns()
List<SchemaPath>	KuduGroupScan.getColumns()

Method parameters in org.apache.drill.exec.store.kudu with type arguments of type SchemaPath

Modifier and Type	Method and Description
boolean	KuduGroupScan.canPushdownProjects(List<SchemaPath> columns)
GroupScan	KuduGroupScan.clone(List<SchemaPath> columns)

Constructor parameters in org.apache.drill.exec.store.kudu with type arguments of type SchemaPath

Constructor and Description
KuduGroupScan(KuduScanSpec kuduScanSpec, KuduStoragePluginConfig kuduStoragePluginConfig, List<SchemaPath> columns, StoragePluginRegistry pluginRegistry)
KuduGroupScan(KuduStoragePlugin kuduStoragePlugin, KuduScanSpec kuduScanSpec, List<SchemaPath> columns)
KuduRecordReader(org.apache.kudu.client.KuduClient client, KuduSubScan.KuduSubScanSpec subScanSpec, List<SchemaPath> projectedColumns)
KuduSubScan(KuduStoragePlugin plugin, List<KuduSubScan.KuduSubScanSpec> tabletInfoList, List<SchemaPath> columns)
KuduSubScan(StoragePluginRegistry registry, KuduStoragePluginConfig kuduStoragePluginConfig, LinkedList<KuduSubScan.KuduSubScanSpec> tabletScanSpecList, List<SchemaPath> columns)

Uses of SchemaPath in org.apache.drill.exec.store.ltsv

Methods in org.apache.drill.exec.store.ltsv that return types with arguments of type SchemaPath

Modifier and Type	Method and Description
protected Collection<SchemaPath>	LTSVRecordReader.transformColumns(Collection<SchemaPath> projected)

Method parameters in org.apache.drill.exec.store.ltsv with type arguments of type SchemaPath

Modifier and Type	Method and Description
RecordReader	LTSVFormatPlugin.getRecordReader(FragmentContext context, DrillFileSystem dfs, FileWork fileWork, List<SchemaPath> columns, String userName)
protected Collection<SchemaPath>	LTSVRecordReader.transformColumns(Collection<SchemaPath> projected)

Constructor parameters in org.apache.drill.exec.store.ltsv with type arguments of type SchemaPath

Constructor and Description
LTSVRecordReader(FragmentContext fragmentContext, org.apache.hadoop.fs.Path path, DrillFileSystem fileSystem, List<SchemaPath> columns)

Uses of SchemaPath in org.apache.drill.exec.store.mapr

Fields in org.apache.drill.exec.store.mapr declared as SchemaPath

Modifier and Type	Field and Description
static SchemaPath	PluginConstants.DOCUMENT_SCHEMA_PATH
static SchemaPath	PluginConstants.ID_SCHEMA_PATH

Uses of SchemaPath in org.apache.drill.exec.store.mapr.db

Fields in org.apache.drill.exec.store.mapr.db with type parameters of type SchemaPath

Modifier and Type	Field and Description
protected List<SchemaPath>	MapRDBGroupScan.columns

Methods in org.apache.drill.exec.store.mapr.db that return types with arguments of type SchemaPath

Modifier and Type	Method and Description
List<SchemaPath>	MapRDBSubScan.getColumns()
List<SchemaPath>	MapRDBGroupScan.getColumns()

Method parameters in org.apache.drill.exec.store.mapr.db with type arguments of type SchemaPath

Modifier and Type	Method and Description
boolean	MapRDBGroupScan.canPushdownProjects(List<SchemaPath> columns)
AbstractGroupScan	MapRDBFormatPlugin.getGroupScan(String userName, FileSelection selection, List<SchemaPath> columns)
AbstractGroupScan	MapRDBFormatPlugin.getGroupScan(String userName, FileSelection selection, List<SchemaPath> columns, com.mapr.db.index.IndexDesc indexDesc, MetadataProviderManager metadataProviderManager)

Constructor parameters in org.apache.drill.exec.store.mapr.db with type arguments of type SchemaPath

Constructor and Description
MapRDBGroupScan(AbstractStoragePlugin storagePlugin, MapRDBFormatPlugin formatPlugin, List<SchemaPath> columns, String userName, TableMetadataProvider metadataProvider)
MapRDBSubScan(StoragePluginRegistry engineRegistry, String userName, MapRDBFormatPluginConfig formatPluginConfig, StoragePluginConfig storageConfig, List<MapRDBSubScanSpec> regionScanSpecList, List<SchemaPath> columns, int maxRecordsToRead, String tableType, TupleMetadata schema)
MapRDBSubScan(String userName, MapRDBFormatPlugin formatPlugin, List<MapRDBSubScanSpec> maprSubScanSpecs, List<SchemaPath> columns, int maxRecordsToRead, String tableType, TupleMetadata schema)
MapRDBSubScan(String userName, MapRDBFormatPlugin formatPlugin, List<MapRDBSubScanSpec> maprSubScanSpecs, List<SchemaPath> columns, String tableType, TupleMetadata schema)
RestrictedMapRDBSubScan(StoragePluginRegistry engineRegistry, String userName, MapRDBFormatPluginConfig formatPluginConfig, StoragePluginConfig storageConfig, List<RestrictedMapRDBSubScanSpec> regionScanSpecList, List<SchemaPath> columns, int maxRecordsToRead, String tableType, TupleMetadata schema)
RestrictedMapRDBSubScan(String userName, MapRDBFormatPlugin formatPlugin, List<RestrictedMapRDBSubScanSpec> maprDbSubScanSpecs, List<SchemaPath> columns, int maxRecordsToRead, String tableType, TupleMetadata schema)

Uses of SchemaPath in org.apache.drill.exec.store.mapr.db.binary

Method parameters in org.apache.drill.exec.store.mapr.db.binary with type arguments of type SchemaPath

Modifier and Type	Method and Description
GroupScan	BinaryTableGroupScan.clone(List<SchemaPath> columns)

Constructor parameters in org.apache.drill.exec.store.mapr.db.binary with type arguments of type SchemaPath

Constructor and Description
BinaryTableGroupScan(String userName, AbstractStoragePlugin storagePlugin, MapRDBFormatPlugin formatPlugin, HBaseScanSpec scanSpec, List<SchemaPath> columns, MapRDBTableStats tableStats, TableMetadataProvider metadataProvider)
BinaryTableGroupScan(String userName, AbstractStoragePlugin storagePlugin, MapRDBFormatPlugin formatPlugin, HBaseScanSpec scanSpec, List<SchemaPath> columns, MetadataProviderManager metadataProviderManager)
BinaryTableGroupScan(String userName, HBaseScanSpec scanSpec, FileSystemConfig storagePluginConfig, MapRDBFormatPluginConfig formatPluginConfig, List<SchemaPath> columns, TupleMetadata schema, StoragePluginRegistry pluginRegistry)

Uses of SchemaPath in org.apache.drill.exec.store.mapr.db.json

Methods in org.apache.drill.exec.store.mapr.db.json that return SchemaPath

Modifier and Type	Method and Description
static SchemaPath	FieldPathHelper.fieldPath2SchemaPath(org.ojai.FieldPath fieldPath) Returns SchemaPath equivalent of the specified FieldPath.

Methods in org.apache.drill.exec.store.mapr.db.json that return types with arguments of type SchemaPath

Modifier and Type	Method and Description
List<SchemaPath>	JsonTableGroupScan.getColumns()
protected Collection<SchemaPath>	MaprDBJsonRecordReader.transformColumns(Collection<SchemaPath> columns)

Methods in org.apache.drill.exec.store.mapr.db.json with parameters of type SchemaPath

Modifier and Type	Method and Description
static org.ojai.FieldPath	FieldPathHelper.schemaPath2FieldPath(SchemaPath column) Returns FieldPath equivalent of the specified SchemaPath.
JsonScanSpec	JsonConditionBuilder.visitSchemaPath(SchemaPath path, Void value)

Method parameters in org.apache.drill.exec.store.mapr.db.json with type arguments of type SchemaPath

Modifier and Type	Method and Description
boolean	JsonTableGroupScan.canPushdownProjects(List<SchemaPath> columns)
GroupScan	RestrictedJsonTableGroupScan.clone(List<SchemaPath> columns)
GroupScan	JsonTableGroupScan.clone(List<SchemaPath> columns)
RestrictedJsonTableGroupScan	JsonTableGroupScan.getRestrictedScan(List<SchemaPath> columns)
void	JsonTableGroupScan.setColumns(List<SchemaPath> columns)
protected Collection<SchemaPath>	MaprDBJsonRecordReader.transformColumns(Collection<SchemaPath> columns)

Constructor parameters in org.apache.drill.exec.store.mapr.db.json with type arguments of type SchemaPath

Constructor and Description
JsonTableGroupScan(String userName, AbstractStoragePlugin storagePlugin, MapRDBFormatPlugin formatPlugin, JsonScanSpec scanSpec, List<SchemaPath> columns, MapRDBStatistics stats, TableMetadataProvider metadataProvider)
JsonTableGroupScan(String userName, AbstractStoragePlugin storagePlugin, MapRDBFormatPlugin formatPlugin, JsonScanSpec scanSpec, List<SchemaPath> columns, MetadataProviderManager metadataProviderManager)
JsonTableGroupScan(String userName, JsonScanSpec scanSpec, FileSystemConfig storagePluginConfig, MapRDBFormatPluginConfig formatPluginConfig, List<SchemaPath> columns, TupleMetadata schema, StoragePluginRegistry pluginRegistry)
MaprDBJsonRecordReader(MapRDBSubScanSpec subScanSpec, MapRDBFormatPlugin formatPlugin, List<SchemaPath> projectedColumns, FragmentContext context, int maxRecords, TupleMetadata schema)
MaprDBJsonRecordReader(MapRDBSubScanSpec subScanSpec, MapRDBFormatPlugin formatPlugin, List<SchemaPath> projectedColumns, FragmentContext context, TupleMetadata schema)
RestrictedJsonRecordReader(MapRDBSubScanSpec subScanSpec, MapRDBFormatPlugin formatPlugin, List<SchemaPath> projectedColumns, FragmentContext context, int maxRecordsToRead, TupleMetadata schema)
RestrictedJsonTableGroupScan(String userName, FileSystemPlugin storagePlugin, MapRDBFormatPlugin formatPlugin, JsonScanSpec scanSpec, List<SchemaPath> columns, MapRDBStatistics statistics, TupleMetadata schema)

Uses of SchemaPath in org.apache.drill.exec.store.mapr.db.util

Methods in org.apache.drill.exec.store.mapr.db.util with parameters of type SchemaPath

Modifier and Type	Method and Description
static org.ojai.FieldPath	FieldPathHelper.schemaPathToFieldPath(SchemaPath schemaPath) Returns FieldPath equivalent of the specified SchemaPath.

Uses of SchemaPath in org.apache.drill.exec.store.mapr.streams

Method parameters in org.apache.drill.exec.store.mapr.streams with type arguments of type SchemaPath

Modifier and Type	Method and Description
AbstractGroupScan	StreamsFormatPlugin.getGroupScan(String userName, FileSelection selection, List<SchemaPath> columns)

Uses of SchemaPath in org.apache.drill.exec.store.mock

Method parameters in org.apache.drill.exec.store.mock with type arguments of type SchemaPath

Modifier and Type	Method and Description
boolean	MockGroupScanPOP.canPushdownProjects(List<SchemaPath> columns)
GroupScan	MockGroupScanPOP.clone(List<SchemaPath> columns)
AbstractGroupScan	MockStorageEngine.getPhysicalScan(String userName, JSONOptions selection, List<SchemaPath> columns)

Uses of SchemaPath in org.apache.drill.exec.store.mongo

Methods in org.apache.drill.exec.store.mongo that return SchemaPath

Modifier and Type	Method and Description
SchemaPath	MongoCompareFunctionProcessor.getPath()

Methods in org.apache.drill.exec.store.mongo that return types with arguments of type SchemaPath

Modifier and Type	Method and Description
List<SchemaPath>	MongoSubScan.getColumns()
List<SchemaPath>	MongoGroupScan.getColumns()
protected Collection<SchemaPath>	MongoRecordReader.transformColumns(Collection<SchemaPath> projectedColumns)

Methods in org.apache.drill.exec.store.mongo with parameters of type SchemaPath

Modifier and Type	Method and Description
Boolean	MongoCompareFunctionProcessor.visitSchemaPath(SchemaPath path, LogicalExpression valueArg)

Method parameters in org.apache.drill.exec.store.mongo with type arguments of type SchemaPath

Modifier and Type	Method and Description
boolean	MongoGroupScan.canPushdownProjects(List<SchemaPath> columns)
GroupScan	MongoGroupScan.clone(List<SchemaPath> columns)
protected Collection<SchemaPath>	MongoRecordReader.transformColumns(Collection<SchemaPath> projectedColumns)

Constructor parameters in org.apache.drill.exec.store.mongo with type arguments of type SchemaPath

Constructor and Description
MongoGroupScan(String userName, MongoScanSpec scanSpec, MongoStoragePluginConfig storagePluginConfig, List<SchemaPath> columns, boolean useAggregate, StoragePluginRegistry pluginRegistry)
MongoGroupScan(String userName, MongoStoragePlugin storagePlugin, MongoScanSpec scanSpec, List<SchemaPath> columns, boolean useAggregate)
MongoRecordReader(BaseMongoSubScanSpec subScanSpec, List<SchemaPath> projectedColumns, FragmentContext context, MongoStoragePlugin plugin)
MongoSubScan(StoragePluginRegistry registry, String userName, StoragePluginConfig mongoPluginConfig, LinkedList<BaseMongoSubScanSpec> chunkScanSpecList, List<SchemaPath> columns)
MongoSubScan(String userName, MongoStoragePlugin storagePlugin, MongoStoragePluginConfig storagePluginConfig, List<BaseMongoSubScanSpec> chunkScanSpecList, List<SchemaPath> columns)

Uses of SchemaPath in org.apache.drill.exec.store.openTSDB

Methods in org.apache.drill.exec.store.openTSDB that return types with arguments of type SchemaPath

Modifier and Type	Method and Description
List<SchemaPath>	OpenTSDBSubScan.getColumns()
List<SchemaPath>	OpenTSDBGroupScan.getColumns()

Method parameters in org.apache.drill.exec.store.openTSDB with type arguments of type SchemaPath

Modifier and Type	Method and Description
boolean	OpenTSDBGroupScan.canPushdownProjects(List<SchemaPath> columns)
GroupScan	OpenTSDBGroupScan.clone(List<SchemaPath> columns)

Constructor parameters in org.apache.drill.exec.store.openTSDB with type arguments of type SchemaPath

Constructor and Description
OpenTSDBGroupScan(OpenTSDBScanSpec openTSDBScanSpec, OpenTSDBStoragePluginConfig openTSDBStoragePluginConfig, List<SchemaPath> columns, StoragePluginRegistry pluginRegistry)
OpenTSDBGroupScan(OpenTSDBStoragePlugin storagePlugin, OpenTSDBScanSpec scanSpec, List<SchemaPath> columns)
OpenTSDBRecordReader(Service client, OpenTSDBSubScan.OpenTSDBSubScanSpec subScanSpec, List<SchemaPath> projectedColumns)
OpenTSDBSubScan(OpenTSDBStoragePlugin plugin, OpenTSDBStoragePluginConfig config, List<OpenTSDBSubScan.OpenTSDBSubScanSpec> tabletInfoList, List<SchemaPath> columns)
OpenTSDBSubScan(StoragePluginRegistry registry, OpenTSDBStoragePluginConfig storage, LinkedList<OpenTSDBSubScan.OpenTSDBSubScanSpec> tabletScanSpecList, List<SchemaPath> columns)

Uses of SchemaPath in org.apache.drill.exec.store.parquet

Fields in org.apache.drill.exec.store.parquet with type parameters of type SchemaPath

Modifier and Type	Field and Description
protected List<SchemaPath>	AbstractParquetRowGroupScan.columns

Methods in org.apache.drill.exec.store.parquet that return types with arguments of type SchemaPath

Modifier and Type	Method and Description
static Map<SchemaPath,ColumnStatistics<?>>	ParquetTableMetadataUtils.addImplicitColumnsStatistics(Map<SchemaPath,ColumnStatistics<?>> columnsStatistics, List<SchemaPath> columns, List<String> partitionValues, OptionManager optionManager, org.apache.hadoop.fs.Path location, boolean supportsFileImplicitColumns) Creates new map based on specified columnStatistics with added statistics for implicit and partition (dir) columns.
List<SchemaPath>	AbstractParquetRowGroupScan.getColumns()
static Map<SchemaPath,ColumnStatistics<?>>	ParquetTableMetadataUtils.getColumnStatistics(TupleMetadata schema, DrillStatsTable statistics) Returns map with schema path and ColumnStatistics obtained from specified DrillStatsTable for all columns from specified BaseTableMetadata.
static Map<SchemaPath,TypeProtos.MajorType>	ParquetTableMetadataUtils.getFileFields(MetadataBase.ParquetTableMetadataBase parquetTableMetadata, MetadataBase.ParquetFileMetadata file) Returns map of column names with their drill types for specified file.
static Map<SchemaPath,TypeProtos.MajorType>	ParquetTableMetadataUtils.getIntermediateFields(MetadataBase.ParquetTableMetadataBase parquetTableMetadata, MetadataBase.RowGroupMetadata rowGroup) Returns map of column names with their Drill types for every NameSegment in SchemaPath in specified rowGroup.
List<SchemaPath>	BaseParquetMetadataProvider.getPartitionColumns()
List<SchemaPath>	ParquetGroupScanStatistics.getPartitionColumns()
static Map<SchemaPath,ColumnStatistics<?>>	ParquetTableMetadataUtils.getRowGroupColumnStatistics(MetadataBase.ParquetTableMetadataBase tableMetadata, MetadataBase.RowGroupMetadata rowGroupMetadata) Converts specified MetadataBase.RowGroupMetadata into the map of ColumnStatistics instances with column names as keys.
static Map<SchemaPath,TypeProtos.MajorType>	ParquetTableMetadataUtils.getRowGroupFields(MetadataBase.ParquetTableMetadataBase parquetTableMetadata, MetadataBase.RowGroupMetadata rowGroup) Returns map of column names with their drill types for specified rowGroup.
Set<SchemaPath>	FilterEvaluatorUtils.FieldReferenceFinder.visitSchemaPath(SchemaPath path, Void value)
Set<SchemaPath>	FilterEvaluatorUtils.FieldReferenceFinder.visitUnknown(LogicalExpression e, Void value)

Methods in org.apache.drill.exec.store.parquet with parameters of type SchemaPath

Modifier and Type	Method and Description
long	ParquetGroupScanStatistics.getColumnValueCount(SchemaPath column)
List<PartitionMetadata>	BaseParquetMetadataProvider.getPartitionMetadata(SchemaPath columnName)
static PartitionMetadata	ParquetTableMetadataUtils.getPartitionMetadata(SchemaPath partitionColumn, List<FileMetadata> files) Returns PartitionMetadata instance received by merging specified FileMetadata list.
Map<org.apache.hadoop.fs.Path,Object>	ParquetGroupScanStatistics.getPartitionPaths(SchemaPath column)
Object	ParquetGroupScanStatistics.getPartitionValue(org.apache.hadoop.fs.Path path, SchemaPath column)
TypeProtos.MajorType	ParquetGroupScanStatistics.getTypeForColumn(SchemaPath schemaPath)
Set<SchemaPath>	FilterEvaluatorUtils.FieldReferenceFinder.visitSchemaPath(SchemaPath path, Void value)

Method parameters in org.apache.drill.exec.store.parquet with type arguments of type SchemaPath

Modifier and Type	Method and Description
static Map<SchemaPath,ColumnStatistics<?>>	ParquetTableMetadataUtils.addImplicitColumnsStatistics(Map<SchemaPath,ColumnStatistics<?>> columnsStatistics, List<SchemaPath> columns, List<String> partitionValues, OptionManager optionManager, org.apache.hadoop.fs.Path location, boolean supportsFileImplicitColumns) Creates new map based on specified columnStatistics with added statistics for implicit and partition (dir) columns.
static Map<SchemaPath,ColumnStatistics<?>>	ParquetTableMetadataUtils.addImplicitColumnsStatistics(Map<SchemaPath,ColumnStatistics<?>> columnsStatistics, List<SchemaPath> columns, List<String> partitionValues, OptionManager optionManager, org.apache.hadoop.fs.Path location, boolean supportsFileImplicitColumns) Creates new map based on specified columnStatistics with added statistics for implicit and partition (dir) columns.
boolean	AbstractParquetGroupScan.canPushdownProjects(List<SchemaPath> columns)
static ParquetReaderUtility.DateCorruptionStatus	ParquetReaderUtility.checkForCorruptDateValuesInStatistics(org.apache.parquet.hadoop.metadata.ParquetMetadata footer, List<SchemaPath> columns, boolean autoCorrectCorruptDates) Detect corrupt date values by looking at the min/max values in the metadata.
GroupScan	ParquetGroupScan.clone(List<SchemaPath> columns)
static boolean	ParquetReaderUtility.containsComplexColumn(org.apache.parquet.hadoop.metadata.ParquetMetadata footer, List<SchemaPath> columns) Check whether any of columns in the given list is either nested or repetitive.
abstract AbstractParquetRowGroupScan	AbstractParquetRowGroupScan.copy(List<SchemaPath> columns)
AbstractParquetRowGroupScan	ParquetRowGroupScan.copy(List<SchemaPath> columns)
static ParquetReaderUtility.DateCorruptionStatus	ParquetReaderUtility.detectCorruptDates(org.apache.parquet.hadoop.metadata.ParquetMetadata footer, List<SchemaPath> columns, boolean autoCorrectCorruptDates) Check for corrupted dates in a parquet file.
protected void	AbstractParquetGroupScan.RowGroupScanFilterer.filterFileMetadata(OptionManager optionManager, FilterPredicate<?> filterPredicate, Set<SchemaPath> schemaPathsInExpr) Produces filtering of metadata at file level.
AbstractFileGroupScan	ParquetFormatPlugin.getGroupScan(String userName, FileSelection selection, List<SchemaPath> columns)
AbstractFileGroupScan	ParquetFormatPlugin.getGroupScan(String userName, FileSelection selection, List<SchemaPath> columns, OptionManager options)
AbstractFileGroupScan	ParquetFormatPlugin.getGroupScan(String userName, FileSelection selection, List<SchemaPath> columns, OptionManager options, MetadataProviderManager metadataProviderManager)
static <T extends Comparable<T>> RowsMatch	FilterEvaluatorUtils.matches(FilterPredicate<T> parquetPredicate, Map<SchemaPath,ColumnStatistics<?>> columnsStatistics, long rowCount, TupleMetadata fileMetadata, Set<SchemaPath> schemaPathsInExpr)
static <T extends Comparable<T>> RowsMatch	FilterEvaluatorUtils.matches(FilterPredicate<T> parquetPredicate, Map<SchemaPath,ColumnStatistics<?>> columnsStatistics, long rowCount, TupleMetadata fileMetadata, Set<SchemaPath> schemaPathsInExpr)
static RowsMatch	FilterEvaluatorUtils.matches(LogicalExpression expr, Map<SchemaPath,ColumnStatistics<?>> columnsStatistics, TupleMetadata schema, long rowCount, UdfUtilities udfUtilities, FunctionLookupContext functionImplementationRegistry, Set<SchemaPath> schemaPathsInExpr)
static RowsMatch	FilterEvaluatorUtils.matches(LogicalExpression expr, Map<SchemaPath,ColumnStatistics<?>> columnsStatistics, TupleMetadata schema, long rowCount, UdfUtilities udfUtilities, FunctionLookupContext functionImplementationRegistry, Set<SchemaPath> schemaPathsInExpr)

Constructor parameters in org.apache.drill.exec.store.parquet with type arguments of type SchemaPath

Constructor and Description
AbstractParquetGroupScan(String userName, List<SchemaPath> columns, List<ReadEntryWithPath> entries, ParquetReaderConfig readerConfig, LogicalExpression filter)
AbstractParquetRowGroupScan(String userName, List<RowGroupReadEntry> rowGroupReadEntries, List<SchemaPath> columns, ParquetReaderConfig readerConfig, LogicalExpression filter, org.apache.hadoop.fs.Path selectionRoot, TupleMetadata schema)
ParquetGroupScan(StoragePluginRegistry engineRegistry, String userName, List<ReadEntryWithPath> entries, StoragePluginConfig storageConfig, FormatPluginConfig formatConfig, List<SchemaPath> columns, org.apache.hadoop.fs.Path selectionRoot, org.apache.hadoop.fs.Path cacheFileRoot, ParquetReaderConfig readerConfig, LogicalExpression filter, TupleMetadata schema)
ParquetGroupScan(String userName, FileSelection selection, ParquetFormatPlugin formatPlugin, List<SchemaPath> columns, ParquetReaderConfig readerConfig, LogicalExpression filter, MetadataProviderManager metadataProviderManager)
ParquetGroupScan(String userName, FileSelection selection, ParquetFormatPlugin formatPlugin, List<SchemaPath> columns, ParquetReaderConfig readerConfig, MetadataProviderManager metadataProviderManager)
ParquetRowGroupScan(StoragePluginRegistry registry, String userName, StoragePluginConfig storageConfig, FormatPluginConfig formatConfig, LinkedList<RowGroupReadEntry> rowGroupReadEntries, List<SchemaPath> columns, ParquetReaderConfig readerConfig, org.apache.hadoop.fs.Path selectionRoot, LogicalExpression filter, TupleMetadata schema)
ParquetRowGroupScan(String userName, ParquetFormatPlugin formatPlugin, List<RowGroupReadEntry> rowGroupReadEntries, List<SchemaPath> columns, ParquetReaderConfig readerConfig, org.apache.hadoop.fs.Path selectionRoot, LogicalExpression filter, TupleMetadata schema)

Uses of SchemaPath in org.apache.drill.exec.store.parquet.columnreaders

Methods in org.apache.drill.exec.store.parquet.columnreaders that return types with arguments of type SchemaPath

Modifier and Type	Method and Description
protected List<SchemaPath>	ParquetRecordReader.getDefaultColumnsToRead()

Constructor parameters in org.apache.drill.exec.store.parquet.columnreaders with type arguments of type SchemaPath

Constructor and Description
ParquetRecordReader(FragmentContext fragmentContext, long numRecordsToRead, org.apache.hadoop.fs.Path path, int rowGroupIndex, org.apache.hadoop.fs.FileSystem fs, org.apache.parquet.compression.CompressionCodecFactory codecFactory, org.apache.parquet.hadoop.metadata.ParquetMetadata footer, List<SchemaPath> columns, ParquetReaderUtility.DateCorruptionStatus dateCorruptionStatus)
ParquetRecordReader(FragmentContext fragmentContext, org.apache.hadoop.fs.Path path, int rowGroupIndex, org.apache.hadoop.fs.FileSystem fs, org.apache.parquet.compression.CompressionCodecFactory codecFactory, org.apache.parquet.hadoop.metadata.ParquetMetadata footer, List<SchemaPath> columns, ParquetReaderUtility.DateCorruptionStatus dateCorruptionStatus)
ParquetRecordReader(FragmentContext fragmentContext, org.apache.hadoop.fs.Path path, int rowGroupIndex, long numRecordsToRead, org.apache.hadoop.fs.FileSystem fs, org.apache.parquet.compression.CompressionCodecFactory codecFactory, org.apache.parquet.hadoop.metadata.ParquetMetadata footer, List<SchemaPath> columns, ParquetReaderUtility.DateCorruptionStatus dateCorruptionStatus)
ParquetSchema(OptionManager options, int rowGroupIndex, org.apache.parquet.hadoop.metadata.ParquetMetadata footer, Collection<SchemaPath> selectedCols) Build the Parquet schema.

Uses of SchemaPath in org.apache.drill.exec.store.parquet.metadata

Fields in org.apache.drill.exec.store.parquet.metadata declared as SchemaPath

Modifier and Type	Field and Description
SchemaPath	Metadata_V1.ColumnMetadata_v1.name

Method parameters in org.apache.drill.exec.store.parquet.metadata with type arguments of type SchemaPath

Modifier and Type	Method and Description
static void	Metadata.createMeta(org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.fs.Path path, ParquetReaderConfig readerConfig, boolean allColumnsInteresting, Set<SchemaPath> columnSet) Create the parquet metadata file for the directory at the given path, and for any subdirectories.
static Metadata_V4.ParquetFileAndRowCountMetadata	Metadata.getParquetFileMetadata_v4(Metadata_V4.ParquetTableMetadata_v4 parquetTableMetadata, org.apache.parquet.hadoop.metadata.ParquetMetadata footer, org.apache.hadoop.fs.FileStatus file, org.apache.hadoop.fs.FileSystem fs, boolean allColumnsInteresting, boolean skipNonInteresting, Set<SchemaPath> columnSet, ParquetReaderConfig readerConfig) Get the file metadata for a single file

Constructors in org.apache.drill.exec.store.parquet.metadata with parameters of type SchemaPath

Constructor and Description
ColumnMetadata_v1(SchemaPath name, org.apache.parquet.schema.PrimitiveType.PrimitiveTypeName primitiveType, org.apache.parquet.schema.OriginalType originalType, Object max, Object min, Long nulls)
Key(SchemaPath name)
Key(SchemaPath name)

Constructor parameters in org.apache.drill.exec.store.parquet.metadata with type arguments of type SchemaPath

Constructor and Description
FileMetadataCollector(org.apache.parquet.hadoop.metadata.ParquetMetadata metadata, org.apache.hadoop.fs.FileStatus file, org.apache.hadoop.fs.FileSystem fs, boolean allColumnsInteresting, boolean skipNonInteresting, Set<SchemaPath> columnSet, ParquetReaderConfig readerConfig)

Uses of SchemaPath in org.apache.drill.exec.store.parquet2

Constructor parameters in org.apache.drill.exec.store.parquet2 with type arguments of type SchemaPath

Constructor and Description
DrillParquetGroupConverter(OutputMutator mutator, BaseWriter baseWriter, org.apache.parquet.schema.GroupType schema, Collection<SchemaPath> columns, OptionManager options, ParquetReaderUtility.DateCorruptionStatus containsCorruptedDates, boolean skipRepeated, String parentName) The constructor is responsible for creation of converters tree and may invoke itself for creation of child converters when nested field is group type field too.
DrillParquetReader(FragmentContext fragmentContext, org.apache.parquet.hadoop.metadata.ParquetMetadata footer, RowGroupReadEntry entry, List<SchemaPath> columns, DrillFileSystem fileSystem, ParquetReaderUtility.DateCorruptionStatus containsCorruptedDates, long recordsToRead)
DrillParquetRecordMaterializer(OutputMutator mutator, org.apache.parquet.schema.MessageType schema, Collection<SchemaPath> columns, OptionManager options, ParquetReaderUtility.DateCorruptionStatus containsCorruptedDates)

Uses of SchemaPath in org.apache.drill.exec.store.phoenix

Methods in org.apache.drill.exec.store.phoenix that return types with arguments of type SchemaPath

Modifier and Type	Method and Description
List<SchemaPath>	PhoenixGroupScan.columns()
List<SchemaPath>	PhoenixSubScan.getColumns()

Method parameters in org.apache.drill.exec.store.phoenix with type arguments of type SchemaPath

Modifier and Type	Method and Description
GroupScan	PhoenixGroupScan.clone(List<SchemaPath> columns)

Constructor parameters in org.apache.drill.exec.store.phoenix with type arguments of type SchemaPath

Constructor and Description
PhoenixGroupScan(PhoenixGroupScan scan, List<SchemaPath> columns)
PhoenixGroupScan(String user, String sql, List<SchemaPath> columns, PhoenixScanSpec scanSpec, PhoenixStoragePlugin plugin)
PhoenixGroupScan(String userName, String sql, List<SchemaPath> columns, PhoenixScanSpec scanSpec, PhoenixStoragePluginConfig config, StoragePluginRegistry plugins)
PhoenixSubScan(String userName, String sql, List<SchemaPath> columns, PhoenixScanSpec scanSpec, PhoenixStoragePlugin plugin)
PhoenixSubScan(String userName, String sql, List<SchemaPath> columns, PhoenixScanSpec scanSpec, StoragePluginConfig config, StoragePluginRegistry registry)

Uses of SchemaPath in org.apache.drill.exec.store.splunk

Methods in org.apache.drill.exec.store.splunk that return types with arguments of type SchemaPath

Modifier and Type	Method and Description
List<SchemaPath>	SplunkGroupScan.columns()
List<SchemaPath>	SplunkSubScan.getColumns()

Method parameters in org.apache.drill.exec.store.splunk with type arguments of type SchemaPath

Modifier and Type	Method and Description
boolean	SplunkGroupScan.canPushdownProjects(List<SchemaPath> columns)
GroupScan	SplunkGroupScan.clone(List<SchemaPath> columns)

Constructor parameters in org.apache.drill.exec.store.splunk with type arguments of type SchemaPath

Constructor and Description
SplunkGroupScan(SplunkGroupScan that, List<SchemaPath> columns) Applies columns.
SplunkGroupScan(SplunkPluginConfig config, List<SchemaPath> columns, SplunkScanSpec splunkScanSpec, Map<String,ExprNode.ColRelOpConstNode> filters, double selectivity, int maxRecords) Deserialize a group scan.
SplunkSubScan(SplunkPluginConfig config, SplunkScanSpec splunkScanSpec, List<SchemaPath> columns, Map<String,ExprNode.ColRelOpConstNode> filters, int maxRecords)

Uses of SchemaPath in org.apache.drill.exec.store.sys

Methods in org.apache.drill.exec.store.sys that return types with arguments of type SchemaPath

Modifier and Type	Method and Description
List<SchemaPath>	SystemTableScan.getColumns()

Method parameters in org.apache.drill.exec.store.sys with type arguments of type SchemaPath

Modifier and Type	Method and Description
GroupScan	SystemTableScan.clone(List<SchemaPath> columns)
AbstractGroupScan	SystemTablePlugin.getPhysicalScan(String userName, JSONOptions selection, List<SchemaPath> columns)

Uses of SchemaPath in org.apache.drill.exec.util

Methods in org.apache.drill.exec.util that return types with arguments of type SchemaPath

Modifier and Type	Method and Description
static Collection<SchemaPath>	EncodedSchemaPathSet.decode(Collection<SchemaPath> encodedPaths) Returns the decoded Collection of SchemaPath from the input which may contain a mix of encoded and non-encoded SchemaPaths.

Methods in org.apache.drill.exec.util with parameters of type SchemaPath

Modifier and Type	Method and Description
static boolean	EncodedSchemaPathSet.isEncodedSchemaPath(SchemaPath schemaPath)

Method parameters in org.apache.drill.exec.util with type arguments of type SchemaPath

Modifier and Type	Method and Description
static Collection<SchemaPath>	EncodedSchemaPathSet.decode(Collection<SchemaPath> encodedPaths) Returns the decoded Collection of SchemaPath from the input which may contain a mix of encoded and non-encoded SchemaPaths.
static boolean	Utilities.isStarQuery(Collection<SchemaPath> projected) Return true if list of schema path has star column.

Uses of SchemaPath in org.apache.drill.exec.vector.complex

Methods in org.apache.drill.exec.vector.complex with parameters of type SchemaPath

Modifier and Type	Method and Description
static TypedFieldId	FieldIdUtil.getFieldId(ValueVector vector, int id, SchemaPath expectedPath, boolean hyper)

Uses of SchemaPath in org.apache.drill.exec.vector.complex.fn

Method parameters in org.apache.drill.exec.vector.complex.fn with type arguments of type SchemaPath

Modifier and Type	Method and Description
static void	JsonReaderUtils.ensureAtLeastOneField(BaseWriter.ComplexWriter writer, Collection<SchemaPath> columns, boolean allTextMode, List<BaseWriter.ListWriter> emptyArrayWriters)
static FieldSelection	FieldSelection.getFieldSelection(List<SchemaPath> fields) Generates a field selection based on a list of fields.
JsonReader.Builder	JsonReader.Builder.schemaPathColumns(List<SchemaPath> columns)
static void	JsonReaderUtils.writeColumnsUsingSchema(BaseWriter.ComplexWriter writer, Collection<SchemaPath> columns, TupleMetadata schema, boolean allTextMode) Creates writers which correspond to the specified schema for specified root writer.

Uses of SchemaPath in org.apache.drill.metastore.metadata

Fields in org.apache.drill.metastore.metadata with type parameters of type SchemaPath

Modifier and Type	Field and Description
protected Map<SchemaPath,ColumnStatistics<?>>	BaseMetadata.columnsStatistics
protected Map<SchemaPath,ColumnStatistics<?>>	BaseMetadata.BaseMetadataBuilder.columnsStatistics

Methods in org.apache.drill.metastore.metadata that return SchemaPath

Modifier and Type	Method and Description
SchemaPath	PartitionMetadata.getColumn() It allows to obtain the column path for this partition
SchemaPath	SegmentMetadata.getColumn()

Methods in org.apache.drill.metastore.metadata that return types with arguments of type SchemaPath

Modifier and Type	Method and Description
Map<SchemaPath,ColumnStatistics<?>>	BaseMetadata.getColumnsStatistics()
Map<SchemaPath,ColumnStatistics<?>>	Metadata.getColumnsStatistics() Returns statistics stored in current metadata represented as Map of column SchemaPaths and corresponding ColumnStatistics.
Map<SchemaPath,ColumnStatistics<?>>	NonInterestingColumnsMetadata.getColumnsStatistics()
List<SchemaPath>	BaseTableMetadata.getInterestingColumns()
List<SchemaPath>	TableMetadata.getInterestingColumns()
List<SchemaPath>	TableMetadataProvider.getPartitionColumns() Returns list of partition columns for table from this TableMetadataProvider.

Methods in org.apache.drill.metastore.metadata with parameters of type SchemaPath

Modifier and Type	Method and Description
PartitionMetadata.PartitionMetadataBuilder	PartitionMetadata.PartitionMetadataBuilder.column(SchemaPath column)
SegmentMetadata.SegmentMetadataBuilder	SegmentMetadata.SegmentMetadataBuilder.column(SchemaPath column)
ColumnMetadata	BaseMetadata.getColumn(SchemaPath name)
ColumnMetadata	Metadata.getColumn(SchemaPath name) Returns metadata description for the specified column
ColumnMetadata	NonInterestingColumnsMetadata.getColumn(SchemaPath name)
ColumnStatistics<?>	BaseMetadata.getColumnStatistics(SchemaPath columnName)
ColumnStatistics<?>	Metadata.getColumnStatistics(SchemaPath columnName) Returns statistics for specified column stored in current metadata.
ColumnStatistics<?>	NonInterestingColumnsMetadata.getColumnStatistics(SchemaPath columnName)
List<PartitionMetadata>	TableMetadataProvider.getPartitionMetadata(SchemaPath columnName) Returns list of PartitionMetadata instances which corresponds to partitions for specified column and provides metadata for specific partitions and its columns.
<V> V	BaseMetadata.getStatisticsForColumn(SchemaPath columnName, StatisticsKind<V> statisticsKind)
<V> V	Metadata.getStatisticsForColumn(SchemaPath columnName, StatisticsKind<V> statisticsKind) Returns value of column statistics which corresponds to specified StatisticsKind for column with specified columnName.
<V> V	NonInterestingColumnsMetadata.getStatisticsForColumn(SchemaPath columnName, StatisticsKind<V> statisticsKind)

Method parameters in org.apache.drill.metastore.metadata with type arguments of type SchemaPath

Modifier and Type	Method and Description
BaseTableMetadata	BaseTableMetadata.cloneWithStats(Map<SchemaPath,ColumnStatistics<?>> columnStatistics, List<StatisticsHolder<?>> tableStatistics)
TableMetadata	TableMetadata.cloneWithStats(Map<SchemaPath,ColumnStatistics<?>> columnStatistics, List<StatisticsHolder<?>> tableStatistics)
T	BaseMetadata.BaseMetadataBuilder.columnsStatistics(Map<SchemaPath,ColumnStatistics<?>> columnsStatistics)
BaseTableMetadata.BaseTableMetadataBuilder	BaseTableMetadata.BaseTableMetadataBuilder.interestingColumns(List<SchemaPath> interestingColumns)

Constructor parameters in org.apache.drill.metastore.metadata with type arguments of type SchemaPath

Constructor and Description
NonInterestingColumnsMetadata(Map<SchemaPath,ColumnStatistics<?>> columnsStatistics)

Uses of SchemaPath in org.apache.drill.metastore.util

Methods in org.apache.drill.metastore.util that return types with arguments of type SchemaPath

Modifier and Type	Method and Description
static <T extends BaseMetadata> Map<SchemaPath,ColumnStatistics<?>>	TableMetadataUtils.mergeColumnsStatistics(Collection<T> metadataList, Set<SchemaPath> columns, List<CollectableColumnStatisticsKind<?>> statisticsToCollect) Merges list of specified metadata into the map of ColumnStatistics with columns as keys.

Methods in org.apache.drill.metastore.util with parameters of type SchemaPath

Modifier and Type	Method and Description
static void	SchemaPathUtils.addColumnMetadata(TupleMetadata schema, SchemaPath schemaPath, TypeProtos.MajorType type, Map<SchemaPath,TypeProtos.MajorType> types) Adds column with specified schema path and type into specified TupleMetadata schema.
static ColumnMetadata	SchemaPathUtils.getColumnMetadata(SchemaPath schemaPath, TupleMetadata schema) Returns ColumnMetadata instance obtained from specified TupleMetadata schema which corresponds to the specified column schema path.
static boolean	SchemaPathUtils.isFieldNestedInDictOrRepeatedMap(SchemaPath schemaPath, TupleMetadata schema) Checks if field identified by the schema path is child in either DICT or REPEATED MAP.

Method parameters in org.apache.drill.metastore.util with type arguments of type SchemaPath

Modifier and Type	Method and Description
static void	SchemaPathUtils.addColumnMetadata(TupleMetadata schema, SchemaPath schemaPath, TypeProtos.MajorType type, Map<SchemaPath,TypeProtos.MajorType> types) Adds column with specified schema path and type into specified TupleMetadata schema.
static <T extends BaseMetadata> Map<SchemaPath,ColumnStatistics<?>>	TableMetadataUtils.mergeColumnsStatistics(Collection<T> metadataList, Set<SchemaPath> columns, List<CollectableColumnStatisticsKind<?>> statisticsToCollect) Merges list of specified metadata into the map of ColumnStatistics with columns as keys.