Package | Description |
---|---|
org.apache.hadoop.examples |
Hadoop example code.
|
org.apache.hadoop.examples.dancing |
This package is a distributed implementation of Knuth's dancing links
algorithm that can run under Hadoop.
|
org.apache.hadoop.examples.pi |
This package consists of a map/reduce application,
distbbp,
which computes exact binary digits of the mathematical constant π.
|
org.apache.hadoop.examples.terasort |
This package consists of 3 map/reduce applications for Hadoop to
compete in the annual terabyte sort
competition.
|
org.apache.hadoop.mapred.gridmix | |
org.apache.hadoop.mapreduce | |
org.apache.hadoop.mapreduce.lib.aggregate | |
org.apache.hadoop.mapreduce.lib.chain | |
org.apache.hadoop.mapreduce.lib.fieldsel | |
org.apache.hadoop.mapreduce.lib.input | |
org.apache.hadoop.mapreduce.lib.map | |
org.apache.hadoop.tools.mapred |
Modifier and Type | Method and Description |
---|---|
protected void |
BaileyBorweinPlouffe.BbpMapper.map(LongWritable offset,
IntWritable length,
Mapper.Context context)
Compute the (offset+1)th to (offset+length)th digits.
|
void |
QuasiMonteCarlo.QmcMapper.map(LongWritable offset,
LongWritable size,
Mapper.Context context)
Map method.
|
void |
SecondarySort.MapClass.map(LongWritable inKey,
Text inValue,
Mapper.Context context) |
void |
MultiFileWordCount.MapClass.map(MultiFileWordCount.WordOffset key,
Text value,
Mapper.Context context) |
void |
WordMedian.WordMedianMapper.map(Object key,
Text value,
Mapper.Context context)
Emits a key-value pair for counting the word.
|
void |
WordCount.TokenizerMapper.map(Object key,
Text value,
Mapper.Context context) |
void |
WordMean.WordMeanMapper.map(Object key,
Text value,
Mapper.Context context)
Emits 2 key-value pairs for counting the word and its length.
|
void |
WordStandardDeviation.WordStandardDeviationMapper.map(Object key,
Text value,
Mapper.Context context)
Emits 3 key-value pairs for counting the word, its length, and the
squares of its length.
|
Modifier and Type | Method and Description |
---|---|
void |
DistributedPentomino.PentMap.map(WritableComparable<?> key,
Text value,
Mapper.Context context)
Break the prefix string into moves (a sequence of integer row ids that
will be selected for each column in order).
|
void |
DistributedPentomino.PentMap.setup(Mapper.Context context) |
Modifier and Type | Method and Description |
---|---|
protected void |
DistSum.ReduceSide.PartitionMapper.map(NullWritable nw,
SummationWritable sigma,
Mapper.Context context)
Partitions sigma into parts
|
protected void |
DistSum.MapSide.SummingMapper.map(NullWritable nw,
SummationWritable sigma,
Mapper.Context context) |
Modifier and Type | Method and Description |
---|---|
void |
TeraGen.SortGenMapper.cleanup(Mapper.Context context) |
void |
TeraGen.SortGenMapper.map(LongWritable row,
NullWritable ignored,
Mapper.Context context) |
Modifier and Type | Method and Description |
---|---|
void |
SleepJob.SleepMapper.cleanup(Mapper.Context context) |
void |
SleepJob.SleepMapper.map(LongWritable key,
LongWritable value,
Mapper.Context context) |
Modifier and Type | Method and Description |
---|---|
static <K1,V1,K2,V2> |
ContextFactory.cloneMapContext(MapContext<K1,V1,K2,V2> context,
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,
Text value,
Mapper.Context context) |
void |
InverseMapper.map(K key,
V value,
Mapper.Context context)
The inverse function.
|
void |
TokenCounterMapper.map(Object key,
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) |
Modifier and Type | Method and Description |
---|---|
void |
CopyMapper.map(Text relPath,
FileStatus sourceFileStatus,
Mapper.Context context)
Implementation of the Mapper<>::map().
|
void |
CopyMapper.setup(Mapper.Context context)
Implementation of the Mapper::setup() method.
|
Copyright © 2013 Apache Software Foundation. All rights reserved.