| 限定符和类型 | 方法和说明 |
|---|---|
abstract RecordReader<K,V> |
InputFormat.createRecordReader(InputSplit split,
TaskAttemptContext context)
Create a record reader for a given split.
|
| 构造器和说明 |
|---|
MapContext(Configuration conf,
TaskAttemptID taskid,
RecordReader<KEYIN,VALUEIN> reader,
RecordWriter<KEYOUT,VALUEOUT> writer,
OutputCommitter committer,
StatusReporter reporter,
InputSplit split) |
Mapper.Context(Configuration conf,
TaskAttemptID taskid,
RecordReader<KEYIN,VALUEIN> reader,
RecordWriter<KEYOUT,VALUEOUT> writer,
OutputCommitter committer,
StatusReporter reporter,
InputSplit split) |
| 限定符和类型 | 类和说明 |
|---|---|
class |
DataDrivenDBRecordReader<T extends DBWritable>
A RecordReader that reads records from a SQL table,
using data-driven WHERE clause splits.
|
class |
DBRecordReader<T extends DBWritable>
A RecordReader that reads records from a SQL table.
|
class |
MySQLDataDrivenDBRecordReader<T extends DBWritable>
A RecordReader that reads records from a MySQL table via DataDrivenDBRecordReader
|
class |
MySQLDBRecordReader<T extends DBWritable>
A RecordReader that reads records from a MySQL table.
|
class |
OracleDataDrivenDBRecordReader<T extends DBWritable>
A RecordReader that reads records from a Oracle table via DataDrivenDBRecordReader
|
class |
OracleDBRecordReader<T extends DBWritable>
A RecordReader that reads records from an Oracle SQL table.
|
| 限定符和类型 | 方法和说明 |
|---|---|
protected RecordReader<LongWritable,T> |
OracleDataDrivenDBInputFormat.createDBRecordReader(DBInputFormat.DBInputSplit split,
Configuration conf) |
protected RecordReader<LongWritable,T> |
DBInputFormat.createDBRecordReader(DBInputFormat.DBInputSplit split,
Configuration conf) |
protected RecordReader<LongWritable,T> |
DataDrivenDBInputFormat.createDBRecordReader(DBInputFormat.DBInputSplit split,
Configuration conf) |
RecordReader<LongWritable,T> |
DBInputFormat.createRecordReader(InputSplit split,
TaskAttemptContext context)
Create a record reader for a given split.
|
| 限定符和类型 | 类和说明 |
|---|---|
class |
CombineFileRecordReader<K,V>
A generic RecordReader that can hand out different recordReaders
for each chunk in a
CombineFileSplit. |
class |
DelegatingRecordReader<K,V>
This is a delegating RecordReader, which delegates the functionality to the
underlying record reader in
TaggedInputSplit |
class |
KeyValueLineRecordReader
This class treats a line in the input as a key/value pair separated by a
separator character.
|
class |
LineRecordReader
Treats keys as offset in file and value as line.
|
static class |
SequenceFileAsBinaryInputFormat.SequenceFileAsBinaryRecordReader
Read records from a SequenceFile as binary (raw) bytes.
|
class |
SequenceFileAsTextRecordReader
This class converts the input keys and values to their String forms by
calling toString() method.
|
class |
SequenceFileRecordReader<K,V>
An
RecordReader for SequenceFiles. |
| 限定符和类型 | 字段和说明 |
|---|---|
protected RecordReader<K,V> |
CombineFileRecordReader.curReader |
| 限定符和类型 | 字段和说明 |
|---|---|
protected Class<? extends RecordReader<K,V>> |
CombineFileRecordReader.rrClass |
protected Constructor<? extends RecordReader<K,V>> |
CombineFileRecordReader.rrConstructor |
| 构造器和说明 |
|---|
CombineFileRecordReader(CombineFileSplit split,
TaskAttemptContext context,
Class<? extends RecordReader<K,V>> rrClass)
A generic RecordReader that can hand out different recordReaders
for each chunk in the CombineFileSplit.
|
| 限定符和类型 | 方法和说明 |
|---|---|
RecordReader<Text,FileStatus> |
UniformSizeInputFormat.createRecordReader(InputSplit split,
TaskAttemptContext context)
Implementation of InputFormat::createRecordReader().
|
| 限定符和类型 | 类和说明 |
|---|---|
class |
DynamicRecordReader<K,V>
The DynamicRecordReader is used in conjunction with the DynamicInputFormat
to implement the "Worker pattern" for DistCp.
|
| 限定符和类型 | 方法和说明 |
|---|---|
RecordReader<K,V> |
DynamicInputFormat.createRecordReader(InputSplit inputSplit,
TaskAttemptContext taskAttemptContext)
Implementation of Inputformat::createRecordReader().
|
Copyright © 2009 The Apache Software Foundation