public class MapJoinMemoryExhaustionHandler extends Object
Modifier and Type | Field and Description |
---|---|
MemoryMXBean |
memoryMXBean |
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.
|
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() |
public final MemoryMXBean memoryMXBean
public MapJoinMemoryExhaustionHandler(SessionState.LogHelper console, double maxMemoryUsage)
public static long getMaxHeapSize()
public void checkMemoryStatus(long tableContainerSize, long numRows) throws MapJoinMemoryExhaustionException
tableContainerSize
- currently table container sizenumRows
- number of rows processedMapJoinMemoryExhaustionException
Copyright © 2016 The Apache Software Foundation. All rights reserved.