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

Class HashJoinMemoryCalculator.PartitionStatSet

java.lang.Object

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

Enclosing interface:

HashJoinMemoryCalculator

public static class HashJoinMemoryCalculator.PartitionStatSet
extends Object

This class represents the memory size statistics for an entire set of partitions.

Constructor Summary

Constructors

Constructor and Description
PartitionStatSet(HashJoinMemoryCalculator.PartitionStat... partitionStats)

Method Summary

Modifier and Type	Method and Description
boolean	allSpilled()
HashJoinMemoryCalculator.PartitionStat	get(int partitionIndex)
long	getConsumedMemory()
List<Integer>	getInMemoryPartitions()
int	getNumInMemoryBatches()
int	getNumInMemoryPartitions()
long	getNumInMemoryRecords()
int	getNumSpilledPartitions()
List<Integer>	getPartitions(boolean spilled)
int	getSize()
List<Integer>	getSpilledPartitions()
String	makeDebugString()
boolean	noneSpilled()
static String	prettyPrintBytes(long byteCount)

Methods inherited from class java.lang.Object

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

Constructor Detail

PartitionStatSet

public PartitionStatSet(HashJoinMemoryCalculator.PartitionStat... partitionStats)

Method Detail

get

public HashJoinMemoryCalculator.PartitionStat get(int partitionIndex)

getSize

public int getSize()

getNumInMemoryRecords

public long getNumInMemoryRecords()

getNumInMemoryBatches

public int getNumInMemoryBatches()

getConsumedMemory

public long getConsumedMemory()

getSpilledPartitions

public List<Integer> getSpilledPartitions()

getInMemoryPartitions

public List<Integer> getInMemoryPartitions()

getPartitions

public List<Integer> getPartitions(boolean spilled)

getNumInMemoryPartitions

public int getNumInMemoryPartitions()

getNumSpilledPartitions

public int getNumSpilledPartitions()

allSpilled

public boolean allSpilled()

noneSpilled

public boolean noneSpilled()

makeDebugString

public String makeDebugString()

prettyPrintBytes

public static String prettyPrintBytes(long byteCount)