org.apache.drill.exec.physical.impl.xsort

Class SortMetrics

java.lang.Object

org.apache.drill.exec.physical.impl.xsort.SortMetrics

public class SortMetrics
extends Object

Constructor Summary

Constructors

Constructor and Description
SortMetrics(OperatorStats stats)

Method Summary

Modifier and Type	Method and Description
long	getInputBatchCount()
long	getInputBytes()
int	getInputRowCount()
int	getMergeCount()
int	getPeakBatchCount()
int	getSpillCount()
long	getWriteBytes()
void	incrMergeCount()
void	incrSpillCount()
void	updateInputMetrics(int rowCount, long batchSize)
void	updateMemory(long freeMem)
void	updatePeakBatches(int bufferedBatchCount)
void	updateWriteBytes(long writeBytes)

Methods inherited from class java.lang.Object

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

Constructor Detail

SortMetrics

public SortMetrics(OperatorStats stats)

Method Detail

updateInputMetrics

public void updateInputMetrics(int rowCount,
                               long batchSize)

updateMemory

public void updateMemory(long freeMem)

getInputRowCount

public int getInputRowCount()

getInputBatchCount

public long getInputBatchCount()

getInputBytes

public long getInputBytes()

updatePeakBatches

public void updatePeakBatches(int bufferedBatchCount)

incrMergeCount

public void incrMergeCount()

incrSpillCount

public void incrSpillCount()

updateWriteBytes

public void updateWriteBytes(long writeBytes)

getSpillCount

public int getSpillCount()

getMergeCount

public int getMergeCount()

getWriteBytes

public long getWriteBytes()

getPeakBatchCount

public int getPeakBatchCount()