org.apache.hadoop.hive.ql.exec
Class ExecMapper

java.lang.Object
  MapReduceBase
      org.apache.hadoop.hive.ql.exec.ExecMapper

public class ExecMapper
extends MapReduceBase

ExecMapper.

Nested Class Summary

static class

ExecMapper.reportStats reportStats.

Field Summary

static org.apache.commons.logging.Log	l4j
static MemoryMXBean	memoryMXBean

Constructor Summary

ExecMapper()

Method Summary

void	close()
void	configure(JobConf job)
static boolean	getDone()
boolean	isAbort()
void	map(Object key, Object value, OutputCollector output, Reporter reporter)
void	setAbort(boolean abort)
static void	setDone(boolean done)

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

memoryMXBean

public static MemoryMXBean memoryMXBean

Constructor Detail

ExecMapper

public ExecMapper()

Method Detail

configure

public void configure(JobConf job)

map

public void map(Object key,
                Object value,
                OutputCollector output,
                Reporter reporter)
         throws IOException

Throws:

IOException

close

public void close()

getDone

public static boolean getDone()

isAbort

public boolean isAbort()

setAbort

public void setAbort(boolean abort)

setDone

public static void setDone(boolean done)