org.apache.hadoop.hive.ql.exec.mapjoin

Class MapJoinMemoryExhaustionHandler

java.lang.Object

org.apache.hadoop.hive.ql.exec.mapjoin.MapJoinMemoryExhaustionHandler

public class MapJoinMemoryExhaustionHandler
extends Object

Handles the logic around deciding when to throw an MapJoinMemoryExhaustionException for HashTableSinkOperator.

Field Summary

Fields

Modifier and Type	Field and Description
MemoryMXBean	memoryMXBean

Constructor Summary

Constructors

Constructor and Description
MapJoinMemoryExhaustionHandler(SessionState.LogHelper console, double maxMemoryUsage) Constructor expects a LogHelper object in addition to the max percent of heap memory which can be consumed before a MapJoinMemoryExhaustionException is thrown.

Method Summary

Modifier and Type	Method and Description
void	checkMemoryStatus(long tableContainerSize, long numRows) Throws MapJoinMemoryExhaustionException when the JVM has consumed the configured percentage of memory.
static long	getMaxHeapSize()

Methods inherited from class java.lang.Object

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

Field Detail

memoryMXBean

public final MemoryMXBean memoryMXBean

Constructor Detail

MapJoinMemoryExhaustionHandler

public MapJoinMemoryExhaustionHandler(SessionState.LogHelper console,
                                      double maxMemoryUsage)

Constructor expects a LogHelper object in addition to the max percent of heap memory which can be consumed before a MapJoinMemoryExhaustionException is thrown.

Method Detail

getMaxHeapSize

public static long getMaxHeapSize()

checkMemoryStatus

public void checkMemoryStatus(long tableContainerSize,
                              long numRows)
                       throws MapJoinMemoryExhaustionError

Throws MapJoinMemoryExhaustionException when the JVM has consumed the configured percentage of memory. The arguments are used simply for the error message.

Parameters:

tableContainerSize - currently table container size

numRows - number of rows processed

Throws:

MapJoinMemoryExhaustionError