public class ExecMapper
extends MapReduceBase
Modifier and Type | Class and Description |
---|---|
static class |
ExecMapper.reportStats
reportStats.
|
Modifier and Type | Field and Description |
---|---|
static org.apache.commons.logging.Log |
l4j |
static java.lang.management.MemoryMXBean |
memoryMXBean |
Constructor and Description |
---|
ExecMapper() |
Modifier and Type | Method and Description |
---|---|
void |
close() |
void |
configure(JobConf job) |
static boolean |
getDone() |
boolean |
isAbort() |
void |
map(java.lang.Object key,
java.lang.Object value,
OutputCollector output,
Reporter reporter) |
void |
setAbort(boolean abort) |
static void |
setDone(boolean done) |
public static final org.apache.commons.logging.Log l4j
public static java.lang.management.MemoryMXBean memoryMXBean
public void configure(JobConf job)
public void map(java.lang.Object key, java.lang.Object value, OutputCollector output, Reporter reporter) throws java.io.IOException
java.io.IOException
public void close()
public static boolean getDone()
public boolean isAbort()
public void setAbort(boolean abort)
public static void setDone(boolean done)
Copyright © 2012 The Apache Software Foundation