Package 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	Description
static final double	HASHTABLE_DOUBLING_FACTOR
static final String	TYPE

Constructor Summary

Constructors

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

HASHTABLE_DOUBLING_FACTOR

public static final double HASHTABLE_DOUBLING_FACTOR

See Also:

• Constant Field Values

Constructor Details

HashTableSizeCalculatorConservativeImpl

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