org.apache.drill.exec.store.parquet

Class ParquetReaderStats

java.lang.Object

org.apache.drill.exec.store.parquet.ParquetReaderStats

public class ParquetReaderStats
extends Object

Field Summary

Fields

Modifier and Type	Field and Description
AtomicLong	numDataPageLoads
AtomicLong	numDataPagesDecoded
AtomicLong	numDataPagesDecompressed
AtomicLong	numDictPageLoads
AtomicLong	numDictPagesDecompressed
AtomicLong	numRowgroups
AtomicLong	rowgroupsPruned
AtomicLong	timeDataPageDecode
AtomicLong	timeDataPageLoads
AtomicLong	timeDataPagesDecompressed
AtomicLong	timeDictPageDecode
AtomicLong	timeDictPageLoads
AtomicLong	timeDictPagesDecompressed
AtomicLong	timeDiskScan
AtomicLong	timeDiskScanWait
AtomicLong	timeFixedColumnRead
AtomicLong	timeProcess
AtomicLong	timeVarColumnRead
AtomicLong	totalDataDecompressedBytes
AtomicLong	totalDataPageReadBytes
AtomicLong	totalDictDecompressedBytes
AtomicLong	totalDictPageReadBytes

Constructor Summary

Constructors

Constructor and Description
ParquetReaderStats()

Method Summary

Modifier and Type	Method and Description
void	logStats(org.slf4j.Logger logger, org.apache.hadoop.fs.Path hadoopPath)
void	update(OperatorStats stats)

Methods inherited from class java.lang.Object

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

Field Detail

numRowgroups

public AtomicLong numRowgroups

rowgroupsPruned

public AtomicLong rowgroupsPruned

numDictPageLoads

public AtomicLong numDictPageLoads

numDataPageLoads

public AtomicLong numDataPageLoads

numDataPagesDecoded

public AtomicLong numDataPagesDecoded

numDictPagesDecompressed

public AtomicLong numDictPagesDecompressed

numDataPagesDecompressed

public AtomicLong numDataPagesDecompressed

totalDictPageReadBytes

public AtomicLong totalDictPageReadBytes

totalDataPageReadBytes

public AtomicLong totalDataPageReadBytes

totalDictDecompressedBytes

public AtomicLong totalDictDecompressedBytes

totalDataDecompressedBytes

public AtomicLong totalDataDecompressedBytes

timeDictPageLoads

public AtomicLong timeDictPageLoads

timeDataPageLoads

public AtomicLong timeDataPageLoads

timeDataPageDecode

public AtomicLong timeDataPageDecode

timeDictPageDecode

public AtomicLong timeDictPageDecode

timeDictPagesDecompressed

public AtomicLong timeDictPagesDecompressed

timeDataPagesDecompressed

public AtomicLong timeDataPagesDecompressed

timeDiskScanWait

public AtomicLong timeDiskScanWait

timeDiskScan

public AtomicLong timeDiskScan

timeFixedColumnRead

public AtomicLong timeFixedColumnRead

timeVarColumnRead

public AtomicLong timeVarColumnRead

timeProcess

public AtomicLong timeProcess

Constructor Detail

ParquetReaderStats

public ParquetReaderStats()

Method Detail

logStats

public void logStats(org.slf4j.Logger logger,
                     org.apache.hadoop.fs.Path hadoopPath)

update

public void update(OperatorStats stats)