org.apache.hadoop.hive.ql.optimizer.spark

Class SparkSkewJoinResolver.SparkSkewJoinProcCtx

java.lang.Object

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

org.apache.hadoop.hive.ql.optimizer.spark.SparkSkewJoinResolver.SparkSkewJoinProcCtx

All Implemented Interfaces:

NodeProcessorCtx

Enclosing class:

SparkSkewJoinResolver

public static class SparkSkewJoinResolver.SparkSkewJoinProcCtx
extends SkewJoinResolver.SkewJoinProcCtx

Constructor Summary

Constructors

Constructor and Description
SparkSkewJoinProcCtx(Task<? extends Serializable> task, ParseContext parseCtx)

Method Summary

Modifier and Type	Method and Description
Map<Operator<?>,ReduceWork>	getReducerToReduceWork()

Methods inherited from class org.apache.hadoop.hive.ql.optimizer.physical.SkewJoinResolver.SkewJoinProcCtx

getCurrentTask, getParseCtx, setCurrentTask, setParseCtx

Methods inherited from class java.lang.Object

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

Constructor Detail

SparkSkewJoinProcCtx

public SparkSkewJoinProcCtx(Task<? extends Serializable> task,
                            ParseContext parseCtx)

Method Detail

getReducerToReduceWork

public Map<Operator<?>,ReduceWork> getReducerToReduceWork()