Modifier and Type | Method and Description |
---|---|
static FileSelection |
FileMetadataInfoCollector.getExpandedFileSelection(FileSelection fileSelection)
Returns
FileSelection file selection based on specified file selection with expanded file statuses. |
Modifier and Type | Method and Description |
---|---|
static FileSelection |
FileMetadataInfoCollector.getExpandedFileSelection(FileSelection fileSelection)
Returns
FileSelection file selection based on specified file selection with expanded file statuses. |
static List<org.apache.hadoop.fs.FileStatus> |
FileMetadataInfoCollector.getFileStatuses(FileSelection fileSelection,
DrillFileSystem fs)
Returns list of
FileStatus file statuses obtained from specified FileSelection file selection. |
Modifier and Type | Method and Description |
---|---|
FileSelection |
MetastoreFileTableMetadataProvider.Builder.selection() |
Modifier and Type | Method and Description |
---|---|
T |
FileTableMetadataProviderBuilder.withSelection(FileSelection selection) |
T |
MetastoreFileTableMetadataProvider.Builder.withSelection(FileSelection selection) |
SimpleFileTableMetadataProvider.Builder |
SimpleFileTableMetadataProvider.Builder.withSelection(FileSelection selection) |
Modifier and Type | Method and Description |
---|---|
T |
ParquetMetadataProviderBuilder.withSelection(FileSelection selection) |
MetastoreParquetTableMetadataProvider.Builder |
MetastoreParquetTableMetadataProvider.Builder.withSelection(FileSelection selection) |
Modifier and Type | Method and Description |
---|---|
protected void |
AbstractGroupScanWithMetadata.checkMetadataConsistency(FileSelection selection,
org.apache.hadoop.conf.Configuration fsConf)
Compares the last modified time of files obtained from specified selection with
the Metastore last modified time to determine whether Metastore metadata
is up-to-date.
|
FileGroupScan |
AbstractFileGroupScan.clone(FileSelection selection) |
FileGroupScan |
FileGroupScan.clone(FileSelection selection) |
void |
AbstractFileGroupScan.modifyFileSelection(FileSelection selection) |
void |
FileGroupScan.modifyFileSelection(FileSelection selection) |
void |
AbstractGroupScanWithMetadata.modifyFileSelection(FileSelection selection) |
Modifier and Type | Method and Description |
---|---|
static List<String> |
ColumnExplorer.getPartitionColumnNames(FileSelection selection,
ColumnNamesOptions columnNamesOptions)
Returns list with partition column names.
|
static int |
ColumnExplorer.getPartitionDepth(FileSelection selection) |
Modifier and Type | Method and Description |
---|---|
static FileSelection |
FileSelection.create(DrillFileSystem fs,
String parent,
String path,
boolean allowAccessOutsideWorkspace) |
static FileSelection |
FileSelection.create(List<org.apache.hadoop.fs.FileStatus> statuses,
List<org.apache.hadoop.fs.Path> files,
org.apache.hadoop.fs.Path root) |
static FileSelection |
FileSelection.create(List<org.apache.hadoop.fs.FileStatus> statuses,
List<org.apache.hadoop.fs.Path> files,
org.apache.hadoop.fs.Path root,
org.apache.hadoop.fs.Path cacheFileRoot,
boolean wasAllPartitionsPruned)
Creates a
selection with the given file statuses/files and selection root. |
static FileSelection |
FileSelection.createFromDirectories(List<org.apache.hadoop.fs.Path> dirPaths,
FileSelection selection,
org.apache.hadoop.fs.Path cacheFileRoot) |
FileSelection |
FormatSelection.getSelection() |
FileSelection |
FileSelection.minusDirectories(DrillFileSystem fs) |
FileSelection |
FormatLocationTransformer.transform(String location,
Function<String,FileSelection> selectionFactory)
Transforms specified location and returns
FileSelection instance with updated location. |
Modifier and Type | Method and Description |
---|---|
static FileSelection |
FileSelection.createFromDirectories(List<org.apache.hadoop.fs.Path> dirPaths,
FileSelection selection,
org.apache.hadoop.fs.Path cacheFileRoot) |
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) |
DrillTable |
BasicFormatMatcher.isReadable(DrillFileSystem fs,
FileSelection selection,
FileSystemPlugin fsPlugin,
String storageEngineName,
SchemaConfig schemaConfig) |
abstract DrillTable |
FormatMatcher.isReadable(DrillFileSystem fs,
FileSelection selection,
FileSystemPlugin fsPlugin,
String storageEngineName,
SchemaConfig schemaConfig) |
Modifier and Type | Method and Description |
---|---|
FileSelection |
FormatLocationTransformer.transform(String location,
Function<String,FileSelection> selectionFactory)
Transforms specified location and returns
FileSelection instance with updated location. |
Constructor and Description |
---|
FileSelection(FileSelection selection)
Copy constructor for convenience.
|
FormatSelection(FormatPluginConfig format,
FileSelection selection) |
Modifier and Type | Method and Description |
---|---|
FileSelection |
EasyGroupScan.getFileSelection() |
Modifier and Type | Method and Description |
---|---|
FileGroupScan |
EasyGroupScan.clone(FileSelection selection) |
AbstractGroupScan |
EasyFormatPlugin.getGroupScan(String userName,
FileSelection selection,
List<SchemaPath> columns) |
AbstractGroupScan |
EasyFormatPlugin.getGroupScan(String userName,
FileSelection selection,
List<SchemaPath> columns,
MetadataProviderManager metadataProviderManager) |
void |
EasyGroupScan.modifyFileSelection(FileSelection selection) |
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) |
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) |
Modifier and Type | Method and Description |
---|---|
HiveDrillNativeParquetScan |
HiveDrillNativeParquetScan.clone(FileSelection selection) |
Modifier and Type | Class and Description |
---|---|
class |
IcebergMetadataFileSelection |
Modifier and Type | Method and Description |
---|---|
FileSelection |
IcebergFormatLocationTransformer.transform(String location,
Function<String,FileSelection> selectionFactory) |
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) |
DrillTable |
IcebergFormatMatcher.isReadable(DrillFileSystem fs,
FileSelection selection,
FileSystemPlugin fsPlugin,
String storageEngineName,
SchemaConfig schemaConfig) |
Modifier and Type | Method and Description |
---|---|
FileSelection |
IcebergFormatLocationTransformer.transform(String location,
Function<String,FileSelection> selectionFactory) |
Constructor and Description |
---|
IcebergMetadataFileSelection(FileSelection selection,
org.apache.iceberg.MetadataTableType metadataTableType) |
Modifier and Type | Method and Description |
---|---|
DrillTable |
TableFormatMatcher.isReadable(DrillFileSystem fs,
FileSelection selection,
FileSystemPlugin fsPlugin,
String storageEngineName,
SchemaConfig schemaConfig) |
Modifier and Type | Method and Description |
---|---|
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) |
String |
MapRDBFormatPlugin.getTableName(FileSelection selection)
Allows to get a table name from FileSelection object
|
DrillTable |
MapRDBFormatMatcher.isReadable(DrillFileSystem fs,
FileSelection selection,
FileSystemPlugin fsPlugin,
String storageEngineName,
SchemaConfig schemaConfig) |
DrillTable |
MapRDBFormatMatcher.isReadableIndex(DrillFileSystem fs,
FileSelection selection,
FileSystemPlugin fsPlugin,
String storageEngineName,
String userName,
IndexDescriptor secondaryIndexDesc)
Get an instance of DrillTable for a particular native secondary index
|
Modifier and Type | Method and Description |
---|---|
AbstractGroupScan |
StreamsFormatPlugin.getGroupScan(String userName,
FileSelection selection,
List<SchemaPath> columns) |
Modifier and Type | Method and Description |
---|---|
FileSelection |
BaseParquetMetadataProvider.Builder.selection() |
Modifier and Type | Method and Description |
---|---|
ParquetGroupScan |
ParquetGroupScan.clone(FileSelection selection) |
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) |
void |
AbstractParquetGroupScan.modifyFileSelection(FileSelection selection) |
T |
BaseParquetMetadataProvider.Builder.withSelection(FileSelection selection) |
Constructor and Description |
---|
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) |
Copyright © 1970 The Apache Software Foundation. All rights reserved.