org.apache.hadoop.hive.ql.exec.mr

Class ExecMapperContext

java.lang.Object

org.apache.hadoop.hive.ql.exec.mr.ExecMapperContext

public class ExecMapperContext
extends Object

Field Summary

Fields

Modifier and Type	Field and Description
static org.apache.commons.logging.Log	l4j

Constructor Summary

Constructors

Constructor and Description
ExecMapperContext(org.apache.hadoop.mapred.JobConf jc)

Method Summary

Methods

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	setIoCxt(IOContext ioCxt)
void	setJc(org.apache.hadoop.mapred.JobConf jc)
void	setLastInputPath(org.apache.hadoop.fs.Path lastInputPath)
void	setLocalWork(MapredLocalWork localWork)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

l4j

public static final org.apache.commons.logging.Log l4j

Constructor Detail

ExecMapperContext

public ExecMapperContext(org.apache.hadoop.mapred.JobConf jc)

Method Detail

getCurrentBigBucketFile

public String getCurrentBigBucketFile()

setCurrentBigBucketFile

public void setCurrentBigBucketFile(String currentBigBucketFile)

clear

public void clear()

inputFileChanged

public 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. If the map local work has any mapping depending on the current mapper's input file, the work need to clear context and re-initialization after the input file changed. This is first introduced to process bucket map join.

Returns:

is the input file changed?

resetRow

public void resetRow()

Reset the execution context for each new row. This function should be called only once at the root of the operator tree -- ExecMapper.map(). Note: this function should be kept minimum since it is called for each input row.

getLastInputPath

public org.apache.hadoop.fs.Path getLastInputPath()

setLastInputPath

public void setLastInputPath(org.apache.hadoop.fs.Path lastInputPath)

getCurrentInputPath

public org.apache.hadoop.fs.Path getCurrentInputPath()

setCurrentInputPath

public void setCurrentInputPath(org.apache.hadoop.fs.Path currentInputPath)

getJc

public org.apache.hadoop.mapred.JobConf getJc()

setJc

public void setJc(org.apache.hadoop.mapred.JobConf jc)

getLocalWork

public MapredLocalWork getLocalWork()

setLocalWork

public void setLocalWork(MapredLocalWork localWork)

getFileId

public String getFileId()

setFileId

public void setFileId(String fileId)

getFetchOperators

public Map<String,FetchOperator> getFetchOperators()

setFetchOperators

public void setFetchOperators(Map<String,FetchOperator> fetchOperators)

getIoCxt

public IOContext getIoCxt()

setIoCxt

public void setIoCxt(IOContext ioCxt)