| Package | Description |
|---|---|
| org.apache.drill.exec.store.hive | |
| org.apache.drill.exec.store.parquet | |
| org.apache.drill.exec.store.parquet2 |
| Modifier and Type | Method and Description |
|---|---|
org.apache.hadoop.conf.Configuration |
HiveDrillNativeParquetRowGroupScan.getFsConf(RowGroupReadEntry rowGroupReadEntry) |
List<String> |
HiveDrillNativeParquetRowGroupScan.getPartitionValues(RowGroupReadEntry rowGroupReadEntry) |
| 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) |
| Modifier and Type | Field and Description |
|---|---|
protected List<RowGroupReadEntry> |
AbstractParquetRowGroupScan.rowGroupReadEntries |
| Modifier and Type | Method and Description |
|---|---|
RowGroupReadEntry |
RowGroupReadEntry.getRowGroupReadEntry() |
RowGroupReadEntry |
RowGroupInfo.getRowGroupReadEntry() |
| Modifier and Type | Method and Description |
|---|---|
protected List<RowGroupReadEntry> |
AbstractParquetGroupScan.getReadEntries(int minorFragmentId) |
List<RowGroupReadEntry> |
AbstractParquetRowGroupScan.getRowGroupReadEntries() |
| Modifier and Type | Method and Description |
|---|---|
org.apache.hadoop.conf.Configuration |
ParquetRowGroupScan.getFsConf(RowGroupReadEntry rowGroupReadEntry) |
abstract org.apache.hadoop.conf.Configuration |
AbstractParquetRowGroupScan.getFsConf(RowGroupReadEntry rowGroupReadEntry) |
List<String> |
ParquetRowGroupScan.getPartitionValues(RowGroupReadEntry rowGroupReadEntry) |
abstract List<String> |
AbstractParquetRowGroupScan.getPartitionValues(RowGroupReadEntry rowGroupReadEntry) |
| Constructor and Description |
|---|
AbstractParquetRowGroupScan(String userName,
List<RowGroupReadEntry> rowGroupReadEntries,
List<SchemaPath> columns,
ParquetReaderConfig readerConfig,
LogicalExpression filter,
org.apache.hadoop.fs.Path selectionRoot,
TupleMetadata schema) |
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) |
| Constructor and Description |
|---|
DrillParquetReader(FragmentContext fragmentContext,
org.apache.parquet.hadoop.metadata.ParquetMetadata footer,
RowGroupReadEntry entry,
List<SchemaPath> columns,
DrillFileSystem fileSystem,
ParquetReaderUtility.DateCorruptionStatus containsCorruptedDates,
long recordsToRead) |
Copyright © 2021 The Apache Software Foundation. All rights reserved.