public static class ConditionalResolverSkewJoin.ConditionalResolverSkewJoinCtx extends Object implements Serializable
Constructor and Description |
---|
ConditionalResolverSkewJoinCtx()
For serialization use only.
|
ConditionalResolverSkewJoinCtx(HashMap<org.apache.hadoop.fs.Path,Task<? extends Serializable>> dirToTaskMap,
List<Task<? extends Serializable>> noSkewTask) |
Modifier and Type | Method and Description |
---|---|
HashMap<org.apache.hadoop.fs.Path,Task<? extends Serializable>> |
getDirToTaskMap() |
List<Task<? extends Serializable>> |
getNoSkewTask() |
void |
setDirToTaskMap(HashMap<org.apache.hadoop.fs.Path,Task<? extends Serializable>> dirToTaskMap) |
void |
setNoSkewTask(List<Task<? extends Serializable>> noSkewTask) |
public ConditionalResolverSkewJoinCtx()
public ConditionalResolverSkewJoinCtx(HashMap<org.apache.hadoop.fs.Path,Task<? extends Serializable>> dirToTaskMap, List<Task<? extends Serializable>> noSkewTask)
public HashMap<org.apache.hadoop.fs.Path,Task<? extends Serializable>> getDirToTaskMap()
public void setDirToTaskMap(HashMap<org.apache.hadoop.fs.Path,Task<? extends Serializable>> dirToTaskMap)
public List<Task<? extends Serializable>> getNoSkewTask()
public void setNoSkewTask(List<Task<? extends Serializable>> noSkewTask)
Copyright © 2016 The Apache Software Foundation. All rights reserved.