public class ExecMapperContext
extends java.lang.Object
Modifier and Type | Field and Description |
---|---|
static org.apache.commons.logging.Log |
l4j |
Constructor and Description |
---|
ExecMapperContext() |
Modifier and Type | Method and Description |
---|---|
void |
clear() |
java.lang.String |
getCurrentBigBucketFile() |
java.lang.String |
getCurrentInputFile() |
java.util.Map<java.lang.String,FetchOperator> |
getFetchOperators() |
java.lang.String |
getFileId() |
IOContext |
getIoCxt() |
JobConf |
getJc() |
java.lang.String |
getLastInputFile() |
MapredLocalWork |
getLocalWork() |
boolean |
inputFileChanged()
For CompbineFileInputFormat, the mapper's input file will be changed on the
fly, and the input file name is passed to jobConf by shims/initNextRecordReader.
|
void |
resetRow()
Reset the execution context for each new row.
|
void |
setCurrentBigBucketFile(java.lang.String currentBigBucketFile) |
void |
setCurrentInputFile(java.lang.String currentInputFile) |
void |
setFetchOperators(java.util.Map<java.lang.String,FetchOperator> fetchOperators) |
void |
setFileId(java.lang.String fileId) |
void |
setIoCxt(IOContext ioCxt) |
void |
setJc(JobConf jc) |
void |
setLastInputFile(java.lang.String lastInputFile) |
void |
setLocalWork(MapredLocalWork localWork) |
public java.lang.String getCurrentBigBucketFile()
public void setCurrentBigBucketFile(java.lang.String currentBigBucketFile)
public void clear()
public boolean inputFileChanged()
public void resetRow()
public java.lang.String getLastInputFile()
public void setLastInputFile(java.lang.String lastInputFile)
public java.lang.String getCurrentInputFile()
public void setCurrentInputFile(java.lang.String currentInputFile)
public JobConf getJc()
public void setJc(JobConf jc)
public MapredLocalWork getLocalWork()
public void setLocalWork(MapredLocalWork localWork)
public java.lang.String getFileId()
public void setFileId(java.lang.String fileId)
public java.util.Map<java.lang.String,FetchOperator> getFetchOperators()
public void setFetchOperators(java.util.Map<java.lang.String,FetchOperator> fetchOperators)
public IOContext getIoCxt()
public void setIoCxt(IOContext ioCxt)
Copyright © 2012 The Apache Software Foundation