org.apache.hadoop.hive.ql.optimizer.physical
Class LocalMapJoinProcFactory

java.lang.Object
  org.apache.hadoop.hive.ql.optimizer.physical.LocalMapJoinProcFactory

public final class LocalMapJoinProcFactory
extends Object

Node processor factory for map join resolver. What it did is to replace the map-join operator in the local map join task with a hash-table dump operator. And if the map join is followed by a group by, the hash-table sink operator/mapjoin operator should be configured to use less memory to avoid OOM in group by operator.

Nested Class Summary

static class	LocalMapJoinProcFactory.LocalMapJoinProcessor LocalMapJoinProcessor.
static class	LocalMapJoinProcFactory.MapJoinFollowedByGroupByProcessor MapJoinFollowByProcessor.

Method Summary

static NodeProcessor	getDefaultProc()
static NodeProcessor	getGroupByProc()
static NodeProcessor	getJoinProc()

Methods inherited from class java.lang.Object

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

Method Detail

getJoinProc

public static NodeProcessor getJoinProc()

getGroupByProc

public static NodeProcessor getGroupByProc()

getDefaultProc

public static NodeProcessor getDefaultProc()