public class HiveDrillNativeParquetRowGroupScan extends AbstractParquetRowGroupScan
Modifier and Type | Field and Description |
---|---|
static String |
OPERATOR_TYPE |
columns, filter, readerConfig, rowGroupReadEntries, schema, selectionRoot
INIT_ALLOCATION, initialAllocation, MAX_ALLOCATION, maxAllocation, userName
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 | Method and Description |
---|---|
AbstractParquetRowGroupScan |
copy(List<SchemaPath> columns) |
Map<String,String> |
getConfProperties() |
org.apache.hadoop.conf.Configuration |
getFsConf(RowGroupReadEntry rowGroupReadEntry) |
HivePartitionHolder |
getHivePartitionHolder() |
HiveStoragePlugin |
getHiveStoragePlugin() |
HiveStoragePluginConfig |
getHiveStoragePluginConfig() |
PhysicalOperator |
getNewWithChildren(List<PhysicalOperator> children)
Regenerate with this node with a new set of children.
|
String |
getOperatorType() |
List<String> |
getPartitionValues(RowGroupReadEntry rowGroupReadEntry) |
boolean |
supportsFileImplicitColumns() |
accept, getColumns, getFilter, getReaderConfig, getReaderConfigForSerialization, getRowGroupReadEntries, getSchema, getSelectionRoot, isExecutable, iterator
accept, getCost, getInitialAllocation, getMaxAllocation, getOperatorId, getSVMode, getUserName, isBufferedOperator, setCost, setMaxAllocation, setOperatorId
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
getCost, getInitialAllocation, getMaxAllocation, getOperatorId, getSVMode, getUserName, isBufferedOperator, setCost, setMaxAllocation, setOperatorId
accept
forEach, spliterator
public static final String OPERATOR_TYPE
public 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) throws ExecutionSetupException
ExecutionSetupException
public HiveDrillNativeParquetRowGroupScan(String userName, HiveStoragePlugin hiveStoragePlugin, List<RowGroupReadEntry> rowGroupReadEntries, List<SchemaPath> columns, HivePartitionHolder hivePartitionHolder, Map<String,String> confProperties, ParquetReaderConfig readerConfig, LogicalExpression filter, TupleMetadata schema)
public HiveStoragePluginConfig getHiveStoragePluginConfig()
public HivePartitionHolder getHivePartitionHolder()
public HiveStoragePlugin getHiveStoragePlugin()
public PhysicalOperator getNewWithChildren(List<PhysicalOperator> children)
PhysicalOperator
public String getOperatorType()
public AbstractParquetRowGroupScan copy(List<SchemaPath> columns)
copy
in class AbstractParquetRowGroupScan
public org.apache.hadoop.conf.Configuration getFsConf(RowGroupReadEntry rowGroupReadEntry) throws IOException
getFsConf
in class AbstractParquetRowGroupScan
IOException
public boolean supportsFileImplicitColumns()
supportsFileImplicitColumns
in class AbstractParquetRowGroupScan
public List<String> getPartitionValues(RowGroupReadEntry rowGroupReadEntry)
getPartitionValues
in class AbstractParquetRowGroupScan
Copyright © 1970 The Apache Software Foundation. All rights reserved.