Package org.apache.drill.exec.store.hive
Class HiveDrillNativeParquetRowGroupScan
java.lang.Object
org.apache.drill.exec.physical.base.AbstractBase
org.apache.drill.exec.store.parquet.AbstractParquetRowGroupScan
org.apache.drill.exec.store.hive.HiveDrillNativeParquetRowGroupScan
- All Implemented Interfaces:
Iterable<PhysicalOperator>
,GraphValue<PhysicalOperator>
,FragmentLeaf
,Leaf
,PhysicalOperator
,Scan
,SubScan
-
Field Summary
Fields inherited from class org.apache.drill.exec.store.parquet.AbstractParquetRowGroupScan
columns, filter, readerConfig, rowGroupReadEntries, schema, selectionRoot
Fields inherited from class org.apache.drill.exec.physical.base.AbstractBase
INIT_ALLOCATION, initialAllocation, MAX_ALLOCATION, maxAllocation, userName
-
Constructor Summary
ConstructorDescriptionHiveDrillNativeParquetRowGroupScan
(String userName, HiveStoragePlugin hiveStoragePlugin, List<RowGroupReadEntry> rowGroupReadEntries, List<SchemaPath> columns, HivePartitionHolder hivePartitionHolder, Map<String, String> confProperties, ParquetReaderConfig readerConfig, LogicalExpression filter, TupleMetadata schema) 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) -
Method Summary
Modifier and TypeMethodDescriptioncopy
(List<SchemaPath> columns) org.apache.hadoop.conf.Configuration
getFsConf
(RowGroupReadEntry rowGroupReadEntry) getNewWithChildren
(List<PhysicalOperator> children) Regenerate with this node with a new set of children.getPartitionValues
(RowGroupReadEntry rowGroupReadEntry) boolean
Methods inherited from class org.apache.drill.exec.store.parquet.AbstractParquetRowGroupScan
accept, getColumns, getFilter, getReaderConfig, getReaderConfigForSerialization, getRowGroupReadEntries, getSchema, getSelectionRoot, isExecutable, isImplicitColumn, iterator
Methods inherited from class org.apache.drill.exec.physical.base.AbstractBase
accept, getCost, getInitialAllocation, getMaxAllocation, getOperatorId, getSVMode, getUserName, isBufferedOperator, setCost, setMaxAllocation, setOperatorId
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.common.graph.GraphValue
accept
Methods inherited from interface java.lang.Iterable
forEach, spliterator
Methods inherited from interface org.apache.drill.exec.physical.base.PhysicalOperator
getCost, getInitialAllocation, getMaxAllocation, getOperatorId, getSVMode, getUserName, isBufferedOperator, setCost, setMaxAllocation, setOperatorId
-
Field Details
-
OPERATOR_TYPE
- See Also:
-
-
Constructor Details
-
HiveDrillNativeParquetRowGroupScan
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- Throws:
ExecutionSetupException
-
HiveDrillNativeParquetRowGroupScan
public HiveDrillNativeParquetRowGroupScan(String userName, HiveStoragePlugin hiveStoragePlugin, List<RowGroupReadEntry> rowGroupReadEntries, List<SchemaPath> columns, HivePartitionHolder hivePartitionHolder, Map<String, String> confProperties, ParquetReaderConfig readerConfig, LogicalExpression filter, TupleMetadata schema)
-
-
Method Details
-
getHiveStoragePluginConfig
-
getHivePartitionHolder
-
getConfProperties
-
getHiveStoragePlugin
-
getNewWithChildren
Description copied from interface:PhysicalOperator
Regenerate with this node with a new set of children. This is used in the case of materialization or optimization. -
getOperatorType
-
copy
- Specified by:
copy
in classAbstractParquetRowGroupScan
-
getFsConf
public org.apache.hadoop.conf.Configuration getFsConf(RowGroupReadEntry rowGroupReadEntry) throws IOException - Specified by:
getFsConf
in classAbstractParquetRowGroupScan
- Throws:
IOException
-
supportsFileImplicitColumns
public boolean supportsFileImplicitColumns()- Specified by:
supportsFileImplicitColumns
in classAbstractParquetRowGroupScan
-
getPartitionValues
- Specified by:
getPartitionValues
in classAbstractParquetRowGroupScan
-