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

Class HashTableSizeCalculatorConservativeImpl

java.lang.Object

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

All Implemented Interfaces:

HashTableSizeCalculator

public class HashTableSizeCalculatorConservativeImpl
extends Object
implements HashTableSizeCalculator

Field Summary

Fields

Modifier and Type	Field and Description
static double	HASHTABLE_DOUBLING_FACTOR
static String	TYPE

Constructor Summary

Constructors

Constructor and Description
HashTableSizeCalculatorConservativeImpl(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	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

HASHTABLE_DOUBLING_FACTOR

public static final double HASHTABLE_DOUBLING_FACTOR

See Also:

Constant Field Values

Constructor Detail

HashTableSizeCalculatorConservativeImpl

public HashTableSizeCalculatorConservativeImpl(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)