org.apache.hadoop.hive.ql.plan

Class ConditionalResolverSkewJoin.ConditionalResolverSkewJoinCtx

java.lang.Object

org.apache.hadoop.hive.ql.plan.ConditionalResolverSkewJoin.ConditionalResolverSkewJoinCtx

All Implemented Interfaces:

Serializable

Enclosing class:

ConditionalResolverSkewJoin

public static class ConditionalResolverSkewJoin.ConditionalResolverSkewJoinCtx
extends Object
implements Serializable

ConditionalResolverSkewJoinCtx.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
ConditionalResolverSkewJoin.ConditionalResolverSkewJoinCtx() For serialization use only.
ConditionalResolverSkewJoin.ConditionalResolverSkewJoinCtx(HashMap<org.apache.hadoop.fs.Path,Task<? extends Serializable>> dirToTaskMap, Task<? extends Serializable> noSkewTask)

Method Summary

Methods

Modifier and Type	Method and Description
HashMap<org.apache.hadoop.fs.Path,Task<? extends Serializable>>	getDirToTaskMap()
Task<? extends Serializable>	getNoSkewTask()
void	setDirToTaskMap(HashMap<org.apache.hadoop.fs.Path,Task<? extends Serializable>> dirToTaskMap)
void	setNoSkewTask(Task<? extends Serializable> noSkewTask)

Methods inherited from class java.lang.Object

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

Constructor Detail

ConditionalResolverSkewJoin.ConditionalResolverSkewJoinCtx

public ConditionalResolverSkewJoin.ConditionalResolverSkewJoinCtx()

For serialization use only.

ConditionalResolverSkewJoin.ConditionalResolverSkewJoinCtx

public ConditionalResolverSkewJoin.ConditionalResolverSkewJoinCtx(HashMap<org.apache.hadoop.fs.Path,Task<? extends Serializable>> dirToTaskMap,
                                                          Task<? extends Serializable> noSkewTask)

Method Detail

getDirToTaskMap

public HashMap<org.apache.hadoop.fs.Path,Task<? extends Serializable>> getDirToTaskMap()

setDirToTaskMap

public void setDirToTaskMap(HashMap<org.apache.hadoop.fs.Path,Task<? extends Serializable>> dirToTaskMap)

getNoSkewTask

public Task<? extends Serializable> getNoSkewTask()

setNoSkewTask

public void setNoSkewTask(Task<? extends Serializable> noSkewTask)