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.io |
Generic i/o code for use when reading and writing data to the network,
to databases, and to files.
|
org.apache.hadoop.mapred | |
org.apache.hadoop.mapred.gridmix | |
org.apache.hadoop.mapred.lib | |
org.apache.hadoop.mapred.lib.db | |
org.apache.hadoop.mapreduce.lib.db | |
org.apache.hadoop.mapreduce.lib.input | |
org.apache.hadoop.mapreduce.lib.reduce | |
org.apache.hadoop.net |
Network-related classes.
|
org.apache.hadoop.tools |
Command-line tools for MapReduce.
|
org.apache.hadoop.typedbytes |
Typed bytes are sequences of bytes in which the first byte is a type code.
|
Modifier and Type | Method and Description |
---|---|
RecordReader<LongWritable,IntWritable> |
BaileyBorweinPlouffe.BbpInputFormat.createRecordReader(InputSplit generic,
TaskAttemptContext context)
Create a record reader for a given split.
|
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) |
protected void |
BaileyBorweinPlouffe.BbpReducer.reduce(LongWritable offset,
Iterable<BytesWritable> values,
Reducer.Context context)
Concatenate map outputs.
|
Modifier and Type | Method and Description |
---|---|
void |
QuasiMonteCarlo.QmcReducer.reduce(BooleanWritable isInside,
Iterable<LongWritable> values,
Reducer.Context context)
Accumulate number of points inside/outside results from the mappers.
|
void |
WordMean.WordMeanReducer.reduce(Text key,
Iterable<LongWritable> values,
Reducer.Context context)
Sums all the individual values within the iterator and writes them to the
same key.
|
void |
WordStandardDeviation.WordStandardDeviationReducer.reduce(Text key,
Iterable<LongWritable> values,
Reducer.Context context)
Sums all the individual values within the iterator and writes them to the
same key.
|
Modifier and Type | Method and Description |
---|---|
void |
TeraGen.SortGenMapper.map(LongWritable row,
NullWritable ignored,
Mapper.Context context) |
Modifier and Type | Method and Description |
---|---|
int |
LongWritable.compareTo(LongWritable o)
Compares two LongWritables.
|
Modifier and Type | Method and Description |
---|---|
LongWritable |
LineRecordReader.createKey() |
Modifier and Type | Method and Description |
---|---|
RecordReader<LongWritable,Text> |
TextInputFormat.getRecordReader(InputSplit genericSplit,
JobConf job,
Reporter reporter) |
Modifier and Type | Method and Description |
---|---|
boolean |
LineRecordReader.next(LongWritable key,
Text value)
Read a line.
|
Modifier and Type | Method and Description |
---|---|
RecordReader<LongWritable,LongWritable> |
SleepJob.SleepInputFormat.createRecordReader(InputSplit split,
TaskAttemptContext context) |
RecordReader<LongWritable,LongWritable> |
SleepJob.SleepInputFormat.createRecordReader(InputSplit split,
TaskAttemptContext context) |
Modifier and Type | Method and Description |
---|---|
void |
SleepJob.SleepMapper.map(LongWritable key,
LongWritable value,
Mapper.Context context) |
Modifier and Type | Method and Description |
---|---|
RecordReader<LongWritable,Text> |
CombineTextInputFormat.getRecordReader(InputSplit split,
JobConf conf,
Reporter reporter) |
RecordReader<LongWritable,Text> |
NLineInputFormat.getRecordReader(InputSplit genericSplit,
JobConf job,
Reporter reporter) |
Modifier and Type | Method and Description |
---|---|
void |
RegexMapper.map(K key,
Text value,
OutputCollector<Text,LongWritable> output,
Reporter reporter) |
void |
TokenCountMapper.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) |
void |
LongSumReducer.reduce(K key,
Iterator<LongWritable> values,
OutputCollector<K,LongWritable> output,
Reporter reporter) |
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 |
DBRecordReader.getCurrentKey()
Get the current key
|
Modifier and Type | Method and Description |
---|---|
protected RecordReader<LongWritable,T> |
DataDrivenDBInputFormat.createDBRecordReader(DBInputFormat.DBInputSplit split,
Configuration conf) |
protected RecordReader<LongWritable,T> |
OracleDataDrivenDBInputFormat.createDBRecordReader(DBInputFormat.DBInputSplit split,
Configuration conf) |
protected RecordReader<LongWritable,T> |
DBInputFormat.createDBRecordReader(DBInputFormat.DBInputSplit split,
Configuration conf) |
RecordReader<LongWritable,T> |
DBInputFormat.createRecordReader(InputSplit split,
TaskAttemptContext context)
Create a record reader for a given split.
|
Modifier and Type | Method and Description |
---|---|
boolean |
DBRecordReader.next(LongWritable key,
T value)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
LongWritable |
LineRecordReader.getCurrentKey() |
Modifier and Type | Method and Description |
---|---|
RecordReader<LongWritable,Text> |
TextInputFormat.createRecordReader(InputSplit split,
TaskAttemptContext context) |
RecordReader<LongWritable,Text> |
CombineTextInputFormat.createRecordReader(InputSplit split,
TaskAttemptContext context) |
RecordReader<LongWritable,Text> |
NLineInputFormat.createRecordReader(InputSplit genericSplit,
TaskAttemptContext context) |
Modifier and Type | Method and Description |
---|---|
void |
LongSumReducer.reduce(KEY key,
Iterable<LongWritable> values,
Reducer.Context context) |
Modifier and Type | Method and Description |
---|---|
void |
SocketOutputStream.transferToFully(FileChannel fileCh,
long position,
int count,
LongWritable waitForWritableTime,
LongWritable transferToTime)
Transfers data from FileChannel using
FileChannel.transferTo(long, long, WritableByteChannel) . |
Modifier and Type | Method and Description |
---|---|
void |
Logalyzer.LogRegexMapper.map(K key,
Text value,
OutputCollector<Text,LongWritable> output,
Reporter reporter) |
Modifier and Type | Method and Description |
---|---|
LongWritable |
TypedBytesWritableInput.readLong() |
LongWritable |
TypedBytesWritableInput.readLong(LongWritable lw) |
Modifier and Type | Method and Description |
---|---|
LongWritable |
TypedBytesWritableInput.readLong(LongWritable lw) |
void |
TypedBytesWritableOutput.writeLong(LongWritable lw) |
Copyright © 2013 Apache Software Foundation. All rights reserved.