Package | Description |
---|---|
org.apache.hadoop.examples |
Hadoop example code.
|
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 |
A software framework for easily writing applications which process vast
amounts of data (multi-terabyte data-sets) parallelly on large clusters
(thousands of nodes) built of commodity hardware in a reliable, fault-tolerant
manner.
|
org.apache.hadoop.mapred.lib |
Library of generally useful mappers, reducers, and partitioners.
|
org.apache.hadoop.mapred.lib.db |
org.apache.hadoop.mapred.lib.db Package
|
org.apache.hadoop.mapreduce.lib.input | |
org.apache.hadoop.mapreduce.lib.reduce |
Modifier and Type | Method and Description |
---|---|
void |
PiEstimator.PiMapper.map(LongWritable offset,
LongWritable size,
OutputCollector<BooleanWritable,LongWritable> out,
Reporter reporter)
Map method.
|
void |
SecondarySort.MapClass.map(LongWritable inKey,
Text inValue,
Mapper.Context context) |
Modifier and Type | Method and Description |
---|---|
void |
PiEstimator.PiMapper.map(LongWritable offset,
LongWritable size,
OutputCollector<BooleanWritable,LongWritable> out,
Reporter reporter)
Map method.
|
void |
PiEstimator.PiReducer.reduce(BooleanWritable isInside,
Iterator<LongWritable> values,
OutputCollector<WritableComparable<?>,Writable> output,
Reporter reporter)
Accumulate number of points inside/outside results from the mappers.
|
Modifier and Type | Method and Description |
---|---|
void |
TeraGen.SortGenMapper.map(LongWritable row,
NullWritable ignored,
OutputCollector<Text,Text> output,
Reporter reporter) |
Modifier and Type | Method and Description |
---|---|
LongWritable |
LineRecordReader.createKey()
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
RecordReader<LongWritable,Text> |
TextInputFormat.getRecordReader(InputSplit genericSplit,
JobConf job,
Reporter reporter)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
boolean |
LineRecordReader.next(LongWritable key,
Text value)
Deprecated.
Read a line.
|
Modifier and Type | Method and Description |
---|---|
RecordReader<LongWritable,Text> |
NLineInputFormat.getRecordReader(InputSplit genericSplit,
JobConf job,
Reporter reporter) |
Modifier and Type | Method and Description |
---|---|
void |
TokenCountMapper.map(K key,
Text value,
OutputCollector<Text,LongWritable> output,
Reporter reporter)
Deprecated.
|
void |
RegexMapper.map(K key,
Text value,
OutputCollector<Text,LongWritable> output,
Reporter reporter) |
void |
LongSumReducer.reduce(K key,
Iterator<LongWritable> values,
OutputCollector<K,LongWritable> output,
Reporter reporter)
Deprecated.
|
void |
LongSumReducer.reduce(K key,
Iterator<LongWritable> values,
OutputCollector<K,LongWritable> output,
Reporter reporter)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
LongWritable |
DBInputFormat.DBRecordReader.createKey()
Create an object of the appropriate type to be used as a key.
|
Modifier and Type | Method and Description |
---|---|
RecordReader<LongWritable,T> |
DBInputFormat.getRecordReader(InputSplit split,
JobConf job,
Reporter reporter)
Get the
RecordReader for the given InputSplit . |
Modifier and Type | Method and Description |
---|---|
boolean |
DBInputFormat.DBRecordReader.next(LongWritable key,
T value)
Reads the next key/value pair from the input for processing.
|
Modifier and Type | Method and Description |
---|---|
LongWritable |
LineRecordReader.getCurrentKey() |
Modifier and Type | Method and Description |
---|---|
RecordReader<LongWritable,Text> |
TextInputFormat.createRecordReader(InputSplit split,
TaskAttemptContext context) |
Modifier and Type | Method and Description |
---|---|
void |
LongSumReducer.reduce(KEY key,
Iterable<LongWritable> values,
Reducer.Context context) |
Copyright © 2010 The Apache Software Foundation