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

Class GenSparkSkewJoinProcessor

java.lang.Object

org.apache.hadoop.hive.ql.optimizer.physical.GenSparkSkewJoinProcessor

public class GenSparkSkewJoinProcessor
extends Object

Copied from GenMRSkewJoinProcessor. It's used for spark task

Method Summary

Methods

Modifier and Type	Method and Description
static void	processSkewJoin(JoinOperator joinOp, Task<? extends Serializable> currTask, ReduceWork reduceWork, ParseContext parseCtx)

Methods inherited from class java.lang.Object

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

Method Detail

processSkewJoin

public static void processSkewJoin(JoinOperator joinOp,
                   Task<? extends Serializable> currTask,
                   ReduceWork reduceWork,
                   ParseContext parseCtx)
                            throws SemanticException

Throws:

SemanticException