Package org.apache.drill.exec.store.parquet

Class ParquetGroupScanStatistics<T extends BaseMetadata & LocationProvider>

java.lang.Object

org.apache.drill.exec.store.parquet.ParquetGroupScanStatistics<T>

public class ParquetGroupScanStatistics<T extends BaseMetadata & LocationProvider>
extends Object

Holds common statistics about data in parquet group scan, including information about total row count, columns counts, partition columns.

Constructor Summary

Constructors

Constructor	Description
ParquetGroupScanStatistics(Collection<T> rowGroupInfos)
ParquetGroupScanStatistics(ParquetGroupScanStatistics<T> that)

Method Summary

Modifier and Type	Method	Description
void	collect(Collection<T> metadataList)
long	getColumnValueCount(SchemaPath column)
List<SchemaPath>	getPartitionColumns()
Map<org.apache.hadoop.fs.Path,Object>	getPartitionPaths(SchemaPath column)
Object	getPartitionValue(org.apache.hadoop.fs.Path path, SchemaPath column)
long	getRowCount()
TypeProtos.MajorType	getTypeForColumn(SchemaPath schemaPath)

Methods inherited from class java.lang.Object

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

Constructor Details

ParquetGroupScanStatistics

public ParquetGroupScanStatistics(Collection<T> rowGroupInfos)

ParquetGroupScanStatistics

public ParquetGroupScanStatistics(ParquetGroupScanStatistics<T> that)

Method Details

getColumnValueCount

public long getColumnValueCount(SchemaPath column)

getPartitionColumns

public List<SchemaPath> getPartitionColumns()

getTypeForColumn

public TypeProtos.MajorType getTypeForColumn(SchemaPath schemaPath)

getRowCount

public long getRowCount()

getPartitionValue

public Object getPartitionValue(org.apache.hadoop.fs.Path path,
 SchemaPath column)

getPartitionPaths

public Map<org.apache.hadoop.fs.Path,Object> getPartitionPaths(SchemaPath column)

collect

public void collect(Collection<T> metadataList)