Modifier and Type | Method and Description |
---|---|
static <K1,V1,K2,V2> |
ContextFactory.cloneMapContext(MapContext<K1,V1,K2,V2> context,
org.apache.hadoop.conf.Configuration conf,
RecordReader<K1,V1> reader,
RecordWriter<K2,V2> writer)
Copy a custom WrappedMapper.Context, optionally replacing
the input and output.
|
Modifier and Type | Method and Description |
---|---|
protected void |
Mapper.cleanup(Mapper.Context context)
Called once at the end of the task.
|
protected void |
Mapper.map(KEYIN key,
VALUEIN value,
Mapper.Context context)
Called once for each key/value pair in the input split.
|
void |
Mapper.run(Mapper.Context context)
Expert users can override this method for more complete control over the
execution of the Mapper.
|
protected void |
Mapper.setup(Mapper.Context context)
Called once at the beginning of the task.
|
Modifier and Type | Method and Description |
---|---|
void |
ValueAggregatorMapper.map(K1 key,
V1 value,
Mapper.Context context)
the map function.
|
void |
ValueAggregatorMapper.setup(Mapper.Context context) |
Modifier and Type | Method and Description |
---|---|
void |
ChainMapper.run(Mapper.Context context) |
protected void |
ChainMapper.setup(Mapper.Context context) |
Modifier and Type | Method and Description |
---|---|
void |
FieldSelectionMapper.map(K key,
V val,
Mapper.Context context)
The identify function.
|
void |
FieldSelectionMapper.setup(Mapper.Context context) |
Modifier and Type | Method and Description |
---|---|
void |
DelegatingMapper.run(Mapper.Context context) |
protected void |
DelegatingMapper.setup(Mapper.Context context) |
Modifier and Type | Class and Description |
---|---|
class |
WrappedMapper.Context |
Modifier and Type | Method and Description |
---|---|
Mapper.Context |
WrappedMapper.getMapContext(MapContext<KEYIN,VALUEIN,KEYOUT,VALUEOUT> mapContext)
Get a wrapped
Mapper.Context for custom implementations. |
Modifier and Type | Method and Description |
---|---|
void |
RegexMapper.map(K key,
org.apache.hadoop.io.Text value,
Mapper.Context context) |
void |
InverseMapper.map(K key,
V value,
Mapper.Context context)
The inverse function.
|
void |
TokenCounterMapper.map(Object key,
org.apache.hadoop.io.Text value,
Mapper.Context context) |
void |
MultithreadedMapper.run(Mapper.Context context)
Run the application's maps using a thread pool.
|
void |
RegexMapper.setup(Mapper.Context context) |
Copyright © 2017 Apache Software Foundation. All Rights Reserved.