public static class ConditionalResolverCommonJoin.ConditionalResolverCommonJoinCtx extends Object implements Serializable
Constructor and Description |
---|
ConditionalResolverCommonJoin.ConditionalResolverCommonJoinCtx() |
Modifier and Type | Method and Description |
---|---|
ConditionalResolverCommonJoin.ConditionalResolverCommonJoinCtx |
clone() |
HashMap<String,Long> |
getAliasToKnownSize() |
Task<? extends Serializable> |
getCommonJoinTask() |
org.apache.hadoop.fs.Path |
getHdfsTmpDir() |
org.apache.hadoop.fs.Path |
getLocalTmpDir() |
HashMap<String,ArrayList<String>> |
getPathToAliases() |
HashMap<Task<? extends Serializable>,Set<String>> |
getTaskToAliases() |
void |
setAliasToKnownSize(HashMap<String,Long> aliasToKnownSize) |
void |
setCommonJoinTask(Task<? extends Serializable> commonJoinTask) |
void |
setHdfsTmpDir(org.apache.hadoop.fs.Path hdfsTmpDir) |
void |
setLocalTmpDir(org.apache.hadoop.fs.Path localTmpDir) |
void |
setPathToAliases(HashMap<String,ArrayList<String>> pathToAliases) |
void |
setTaskToAliases(HashMap<Task<? extends Serializable>,Set<String>> taskToAliases) |
public ConditionalResolverCommonJoin.ConditionalResolverCommonJoinCtx()
public HashMap<Task<? extends Serializable>,Set<String>> getTaskToAliases()
public void setTaskToAliases(HashMap<Task<? extends Serializable>,Set<String>> taskToAliases)
public Task<? extends Serializable> getCommonJoinTask()
public void setCommonJoinTask(Task<? extends Serializable> commonJoinTask)
public org.apache.hadoop.fs.Path getLocalTmpDir()
public void setLocalTmpDir(org.apache.hadoop.fs.Path localTmpDir)
public org.apache.hadoop.fs.Path getHdfsTmpDir()
public void setHdfsTmpDir(org.apache.hadoop.fs.Path hdfsTmpDir)
public ConditionalResolverCommonJoin.ConditionalResolverCommonJoinCtx clone()
Copyright © 2017 The Apache Software Foundation. All rights reserved.