public class MapredLocalWork
extends java.lang.Object
implements java.io.Serializable
Constructor and Description |
---|
MapredLocalWork() |
MapredLocalWork(java.util.LinkedHashMap<java.lang.String,Operator<? extends OperatorDesc>> aliasToWork,
java.util.LinkedHashMap<java.lang.String,FetchWork> aliasToFetchWork) |
MapredLocalWork(MapredLocalWork clone) |
Modifier and Type | Method and Description |
---|---|
BucketMapJoinContext |
copyPartSpecMappingOnly() |
void |
deriveExplainAttributes() |
java.util.LinkedHashMap<java.lang.String,FetchWork> |
getAliasToFetchWork() |
java.util.LinkedHashMap<java.lang.String,Operator<? extends OperatorDesc>> |
getAliasToWork() |
java.lang.String |
getBucketFileName(java.lang.String bigFileName) |
BucketMapJoinContext |
getBucketMapjoinContext() |
BucketMapJoinContext |
getBucketMapjoinContextExplain() |
java.util.List<Operator<? extends OperatorDesc>> |
getDummyParentOp() |
boolean |
getInputFileChangeSensitive() |
java.lang.String |
getStageID() |
java.lang.String |
getTmpFileURI() |
void |
setAliasToFetchWork(java.util.LinkedHashMap<java.lang.String,FetchWork> aliasToFetchWork) |
void |
setAliasToWork(java.util.LinkedHashMap<java.lang.String,Operator<? extends OperatorDesc>> aliasToWork) |
void |
setBucketMapjoinContext(BucketMapJoinContext bucketMapjoinContext) |
void |
setDummyParentOp(java.util.List<Operator<? extends OperatorDesc>> op) |
void |
setInputFileChangeSensitive(boolean inputFileChangeSensitive) |
void |
setStageID(java.lang.String stageID) |
void |
setTmpFileURI(java.lang.String tmpFileURI) |
public MapredLocalWork()
public MapredLocalWork(java.util.LinkedHashMap<java.lang.String,Operator<? extends OperatorDesc>> aliasToWork, java.util.LinkedHashMap<java.lang.String,FetchWork> aliasToFetchWork)
public MapredLocalWork(MapredLocalWork clone)
public void setDummyParentOp(java.util.List<Operator<? extends OperatorDesc>> op)
public java.util.List<Operator<? extends OperatorDesc>> getDummyParentOp()
public java.util.LinkedHashMap<java.lang.String,Operator<? extends OperatorDesc>> getAliasToWork()
public java.lang.String getStageID()
public void setStageID(java.lang.String stageID)
public void setAliasToWork(java.util.LinkedHashMap<java.lang.String,Operator<? extends OperatorDesc>> aliasToWork)
public java.util.LinkedHashMap<java.lang.String,FetchWork> getAliasToFetchWork()
public void setAliasToFetchWork(java.util.LinkedHashMap<java.lang.String,FetchWork> aliasToFetchWork)
aliasToFetchWork
- the aliasToFetchWork to setpublic boolean getInputFileChangeSensitive()
public void setInputFileChangeSensitive(boolean inputFileChangeSensitive)
public void deriveExplainAttributes()
public BucketMapJoinContext getBucketMapjoinContextExplain()
public BucketMapJoinContext getBucketMapjoinContext()
public void setBucketMapjoinContext(BucketMapJoinContext bucketMapjoinContext)
public BucketMapJoinContext copyPartSpecMappingOnly()
public void setTmpFileURI(java.lang.String tmpFileURI)
public java.lang.String getTmpFileURI()
public java.lang.String getBucketFileName(java.lang.String bigFileName)
Copyright © 2012 The Apache Software Foundation