public class ExecMapperContext extends Object
Constructor and Description |
---|
ExecMapperContext(org.apache.hadoop.mapred.JobConf jc) |
Modifier and Type | Method and Description |
---|---|
void |
clear() |
String |
getCurrentBigBucketFile() |
org.apache.hadoop.fs.Path |
getCurrentInputPath() |
Map<String,FetchOperator> |
getFetchOperators() |
String |
getFileId() |
IOContext |
getIoCxt() |
org.apache.hadoop.mapred.JobConf |
getJc() |
org.apache.hadoop.fs.Path |
getLastInputPath() |
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(String currentBigBucketFile) |
void |
setCurrentInputPath(org.apache.hadoop.fs.Path currentInputPath) |
void |
setFetchOperators(Map<String,FetchOperator> fetchOperators) |
void |
setFileId(String fileId) |
void |
setJc(org.apache.hadoop.mapred.JobConf jc) |
void |
setLastInputPath(org.apache.hadoop.fs.Path lastInputPath) |
void |
setLocalWork(MapredLocalWork localWork) |
public String getCurrentBigBucketFile()
public void setCurrentBigBucketFile(String currentBigBucketFile)
public void clear()
public boolean inputFileChanged()
public void resetRow()
public org.apache.hadoop.fs.Path getLastInputPath()
public void setLastInputPath(org.apache.hadoop.fs.Path lastInputPath)
public org.apache.hadoop.fs.Path getCurrentInputPath()
public void setCurrentInputPath(org.apache.hadoop.fs.Path currentInputPath)
public org.apache.hadoop.mapred.JobConf getJc()
public void setJc(org.apache.hadoop.mapred.JobConf jc)
public MapredLocalWork getLocalWork()
public void setLocalWork(MapredLocalWork localWork)
public String getFileId()
public void setFileId(String fileId)
public Map<String,FetchOperator> getFetchOperators()
public void setFetchOperators(Map<String,FetchOperator> fetchOperators)
public IOContext getIoCxt()
Copyright © 2016 The Apache Software Foundation. All rights reserved.