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
HashPartition(int initialCapacity, float loadFactor, int wbSize, long maxProbeSize, boolean createHashMap, String spillLocalDirs)

Method Summary

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

Methods inherited from class java.lang.Object

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

Constructor Detail

HashPartition

public HashPartition(int initialCapacity,
                     float loadFactor,
                     int wbSize,
                     long maxProbeSize,
                     boolean createHashMap,
                     String spillLocalDirs)

Method Detail

getHashMapFromMemory

public BytesBytesMultiHashMap getHashMapFromMemory()

getHashMapFromDisk

public BytesBytesMultiHashMap getHashMapFromDisk(int rowCount)
                                          throws IOException,
                                                 ClassNotFoundException

Throws:

IOException

ClassNotFoundException

getSidefileKVContainer

public KeyValueContainer getSidefileKVContainer()

getMatchfileObjContainer

public ObjectContainer getMatchfileObjContainer()

getMatchfileRowBytesContainer

public VectorRowBytesContainer getMatchfileRowBytesContainer()

isHashMapOnDisk

public boolean isHashMapOnDisk()

clear

public void clear()

size

public int size()