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

Class HashTableSizeCalculatorLeanImpl

java.lang.Object

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

All Implemented Interfaces:

HashTableSizeCalculator

public class HashTableSizeCalculatorLeanImpl
extends Object
implements HashTableSizeCalculator

Field Summary

Fields

Modifier and Type	Field	Description
static final String	TYPE

Constructor Summary

Constructors

Constructor	Description
HashTableSizeCalculatorLeanImpl(int maxNumRecords, double hashTableDoublingFactor)

Method Summary

Modifier and Type	Method	Description
long	calculateSize(HashJoinMemoryCalculator.PartitionStat partitionStat, Map<String,Long> keySizes, double loadFactor, double safetyFactor, double fragmentationFactor)
static long	computeMaxVectorSize(Map<String,Long> vectorSizes, long numRecords, double safetyFactor)
static long	computeVectorSizes(Map<String,Long> vectorSizes, long numRecords, double safetyFactor)
double	getDoublingFactor()
String	getType()

Methods inherited from class java.lang.Object

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

Field Details

TYPE

public static final String TYPE

See Also:

• Constant Field Values

Constructor Details

HashTableSizeCalculatorLeanImpl

public HashTableSizeCalculatorLeanImpl(int maxNumRecords,
 double hashTableDoublingFactor)

Method Details

calculateSize

public long calculateSize(HashJoinMemoryCalculator.PartitionStat partitionStat,
 Map<String,Long> keySizes,
 double loadFactor,
 double safetyFactor,
 double fragmentationFactor)

Specified by:

calculateSize in interface HashTableSizeCalculator

getDoublingFactor

public double getDoublingFactor()

Specified by:

getDoublingFactor in interface HashTableSizeCalculator

getType

public String getType()

Specified by:

getType in interface HashTableSizeCalculator

computeVectorSizes

public static long computeVectorSizes(Map<String,Long> vectorSizes,
 long numRecords,
 double safetyFactor)

computeMaxVectorSize

public static long computeMaxVectorSize(Map<String,Long> vectorSizes,
 long numRecords,
 double safetyFactor)