org.apache.drill.exec.metastore.analyze

Class AnalyzeFileInfoProvider

java.lang.Object

org.apache.drill.exec.metastore.analyze.AnalyzeFileInfoProvider

All Implemented Interfaces:

AnalyzeInfoProvider

Direct Known Subclasses:

AnalyzeFileInfoProviderImpl, AnalyzeParquetInfoProvider

public abstract class AnalyzeFileInfoProvider
extends Object
implements AnalyzeInfoProvider

Implementation of AnalyzeInfoProvider for file-based tables.

Constructor Summary

Constructors

Constructor and Description
AnalyzeFileInfoProvider()

Method Summary

Modifier and Type	Method and Description
SchemaPath	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`.
MetadataInfoCollector	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.
NamedExpression	getParentLocationExpression(SchemaPath locationField) Returns expression which may be used to determine parent location for specific table data, i.e.
List<SchemaPath>	getProjectionFields(DrillTable table, MetadataType metadataLevel, ColumnNamesOptions columnNamesOptions) Returns list of fields required for ANALYZE.
List<SchemaPath>	getSegmentColumns(DrillTable table, ColumnNamesOptions columnNamesOptions) Returns list of segment column names for specified DrillTable table.

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.drill.exec.metastore.analyze.AnalyzeInfoProvider

getTableTypeName, supportsGroupScan, supportsMetadataType

Constructor Detail

AnalyzeFileInfoProvider

public AnalyzeFileInfoProvider()

Method Detail

getSegmentColumns

public List<SchemaPath> getSegmentColumns(DrillTable table,
                                          ColumnNamesOptions columnNamesOptions)
                                   throws IOException

Description copied from interface: AnalyzeInfoProvider

Returns list of segment column names for specified DrillTable table.

Specified by:

getSegmentColumns in interface AnalyzeInfoProvider

Parameters:

table - table for which should be returned segment column names

columnNamesOptions - column names option values

Returns:

list of segment column names

Throws:

IOException

getProjectionFields

public List<SchemaPath> getProjectionFields(DrillTable table,
                                            MetadataType metadataLevel,
                                            ColumnNamesOptions columnNamesOptions)
                                     throws IOException

Description copied from interface: AnalyzeInfoProvider

Returns list of fields required for ANALYZE.

Specified by:

getProjectionFields in interface AnalyzeInfoProvider

Parameters:

table - drill table

metadataLevel - metadata level for analyze

columnNamesOptions - column names option values

Returns:

list of fields required for ANALYZE

Throws:

IOException

getMetadataInfoCollector

public MetadataInfoCollector getMetadataInfoCollector(BasicTablesRequests basicRequests,
                                                      TableInfo tableInfo,
                                                      FormatSelection selection,
                                                      PlannerSettings settings,
                                                      Supplier<org.apache.calcite.rel.core.TableScan> tableScanSupplier,
                                                      List<SchemaPath> interestingColumns,
                                                      MetadataType metadataLevel,
                                                      int segmentColumnsCount)
                                               throws IOException

Description copied from interface: AnalyzeInfoProvider

Returns MetadataInfoCollector instance for obtaining information about segments, files, etc. which should be handled in metastore.

Specified by:

getMetadataInfoCollector in interface AnalyzeInfoProvider

Parameters:

basicRequests - Metastore tables data provider helper

tableInfo - table info

selection - format selection

settings - planner settings

tableScanSupplier - supplier for table scan

interestingColumns - list of interesting columns

metadataLevel - metadata level

segmentColumnsCount - number of segment columns

Returns:

MetadataInfoCollector instance

Throws:

IOException

getLocationField

public SchemaPath getLocationField(ColumnNamesOptions columnNamesOptions)

Description copied from interface: AnalyzeInfoProvider

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`.

Specified by:

getLocationField in interface AnalyzeInfoProvider

Parameters:

columnNamesOptions - column names option values

Returns:

location field

getParentLocationExpression

public NamedExpression getParentLocationExpression(SchemaPath locationField)

Description copied from interface: AnalyzeInfoProvider

Returns expression which may be used to determine parent location for specific table data, i.e. segment location. For example, for file-based tables, such expression will be `parentPath` function call.

Specified by:

getParentLocationExpression in interface AnalyzeInfoProvider

Parameters:

locationField - location field

Returns:

expression to determine parent location