org.apache.drill.exec.physical.impl.join

Class PartitionStatImpl

java.lang.Object

org.apache.drill.exec.physical.impl.join.PartitionStatImpl

All Implemented Interfaces:

HashJoinMemoryCalculator.PartitionStat

public class PartitionStatImpl
extends Object
implements HashJoinMemoryCalculator.PartitionStat

This class represents the memory size statistics for an entire partition.

Constructor Summary

Constructors

Constructor and Description
PartitionStatImpl()

Method Summary

Modifier and Type	Method and Description
void	add(HashJoinMemoryCalculator.BatchStat batchStat)
List<HashJoinMemoryCalculator.BatchStat>	getInMemoryBatches()
long	getInMemorySize()
int	getNumInMemoryBatches()
long	getNumInMemoryRecords()
boolean	isSpilled()
void	spill()

Methods inherited from class java.lang.Object

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

Constructor Detail

PartitionStatImpl

public PartitionStatImpl()

Method Detail

add

public void add(HashJoinMemoryCalculator.BatchStat batchStat)

spill

public void spill()

getInMemoryBatches

public List<HashJoinMemoryCalculator.BatchStat> getInMemoryBatches()

Specified by:

getInMemoryBatches in interface HashJoinMemoryCalculator.PartitionStat

getNumInMemoryBatches

public int getNumInMemoryBatches()

Specified by:

getNumInMemoryBatches in interface HashJoinMemoryCalculator.PartitionStat

isSpilled

public boolean isSpilled()

Specified by:

isSpilled in interface HashJoinMemoryCalculator.PartitionStat

getNumInMemoryRecords

public long getNumInMemoryRecords()

Specified by:

getNumInMemoryRecords in interface HashJoinMemoryCalculator.PartitionStat

getInMemorySize

public long getInMemorySize()

Specified by:

getInMemorySize in interface HashJoinMemoryCalculator.PartitionStat