org.apache.hadoop.hive.ql.exec.persistence

Class HybridHashTableContainer.HashPartition

java.lang.Object

org.apache.hadoop.hive.ql.exec.persistence.HybridHashTableContainer.HashPartition

Enclosing class:

HybridHashTableContainer

public static class HybridHashTableContainer.HashPartition
extends Object

This class encapsulates the triplet together since they are closely related to each other The triplet: hashmap (either in memory or on disk), small table container, big table container

Constructor Summary

Constructors

Constructor and Description
HybridHashTableContainer.HashPartition(int threshold, float loadFactor, int wbSize, long memUsage, boolean createHashMap)

Method Summary

Methods

Modifier and Type	Method and Description
void	clear()
BytesBytesMultiHashMap	getHashMapFromDisk(int initialCapacity)
BytesBytesMultiHashMap	getHashMapFromMemory()
ObjectContainer	getMatchfileObjContainer()
VectorMapJoinRowBytesContainer	getMatchfileRowBytesContainer()
KeyValueContainer	getSidefileKVContainer()
boolean	isHashMapOnDisk()

Methods inherited from class java.lang.Object

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

Constructor Detail

HybridHashTableContainer.HashPartition

public HybridHashTableContainer.HashPartition(int threshold,
                                      float loadFactor,
                                      int wbSize,
                                      long memUsage,
                                      boolean createHashMap)

Method Detail

getHashMapFromMemory

public BytesBytesMultiHashMap getHashMapFromMemory()

getHashMapFromDisk

public BytesBytesMultiHashMap getHashMapFromDisk(int initialCapacity)
                                          throws IOException,
                                                 ClassNotFoundException

Throws:

IOException

ClassNotFoundException

getSidefileKVContainer

public KeyValueContainer getSidefileKVContainer()

getMatchfileObjContainer

public ObjectContainer getMatchfileObjContainer()

getMatchfileRowBytesContainer

public VectorMapJoinRowBytesContainer getMatchfileRowBytesContainer()

isHashMapOnDisk

public boolean isHashMapOnDisk()

clear

public void clear()