public static class ConditionalResolverCommonJoin.ConditionalResolverCommonJoinCtx
extends java.lang.Object
implements java.io.Serializable
Constructor and Description |
---|
ConditionalResolverCommonJoinCtx() |
Modifier and Type | Method and Description |
---|---|
java.util.HashMap<java.lang.String,java.lang.Long> |
getAliasToKnownSize() |
java.util.HashMap<java.lang.String,Task<? extends java.io.Serializable>> |
getAliasToTask() |
Task<? extends java.io.Serializable> |
getCommonJoinTask() |
java.lang.String |
getHdfsTmpDir() |
java.lang.String |
getLocalTmpDir() |
java.util.HashMap<java.lang.String,java.util.ArrayList<java.lang.String>> |
getPathToAliases() |
void |
setAliasToKnownSize(java.util.HashMap<java.lang.String,java.lang.Long> aliasToKnownSize) |
void |
setAliasToTask(java.util.HashMap<java.lang.String,Task<? extends java.io.Serializable>> aliasToTask) |
void |
setCommonJoinTask(Task<? extends java.io.Serializable> commonJoinTask) |
void |
setHdfsTmpDir(java.lang.String hdfsTmpDir) |
void |
setLocalTmpDir(java.lang.String localTmpDir) |
void |
setPathToAliases(java.util.HashMap<java.lang.String,java.util.ArrayList<java.lang.String>> pathToAliases) |
public java.util.HashMap<java.lang.String,Task<? extends java.io.Serializable>> getAliasToTask()
public void setAliasToTask(java.util.HashMap<java.lang.String,Task<? extends java.io.Serializable>> aliasToTask)
public Task<? extends java.io.Serializable> getCommonJoinTask()
public void setCommonJoinTask(Task<? extends java.io.Serializable> commonJoinTask)
public java.util.HashMap<java.lang.String,java.lang.Long> getAliasToKnownSize()
public void setAliasToKnownSize(java.util.HashMap<java.lang.String,java.lang.Long> aliasToKnownSize)
public java.util.HashMap<java.lang.String,java.util.ArrayList<java.lang.String>> getPathToAliases()
public void setPathToAliases(java.util.HashMap<java.lang.String,java.util.ArrayList<java.lang.String>> pathToAliases)
public java.lang.String getLocalTmpDir()
public void setLocalTmpDir(java.lang.String localTmpDir)
public java.lang.String getHdfsTmpDir()
public void setHdfsTmpDir(java.lang.String hdfsTmpDir)
Copyright © 2012 The Apache Software Foundation