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 and Description
static String	TYPE

Constructor Summary

Constructors

Constructor and Description
HashTableSizeCalculatorLeanImpl(int maxNumRecords, double hashTableDoublingFactor)

Method Summary

Modifier and Type	Method and 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 Detail

TYPE

public static final String TYPE

See Also:

Constant Field Values

Constructor Detail

HashTableSizeCalculatorLeanImpl

public HashTableSizeCalculatorLeanImpl(int maxNumRecords,
                                       double hashTableDoublingFactor)

Method Detail

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)