org.apache.hadoop.examples

类 MultiFileWordCount.MultiFileLineRecordReader

java.lang.Object

org.apache.hadoop.examples.MultiFileWordCount.MultiFileLineRecordReader

所有已实现的接口:

RecordReader<MultiFileWordCount.WordOffset,Text>

封闭类:

MultiFileWordCount

public static class MultiFileWordCount.MultiFileLineRecordReader
extends Object
implements RecordReader<MultiFileWordCount.WordOffset,Text>

RecordReader is responsible from extracting records from the InputSplit. This record reader accepts a MultiFileSplit, which encapsulates several files, and no file is divided.

构造器概要

构造器

构造器和说明
MultiFileWordCount.MultiFileLineRecordReader(Configuration conf, MultiFileSplit split)

方法概要

方法

限定符和类型	方法和说明
void	close() Close this InputSplit to future operations.
MultiFileWordCount.WordOffset	createKey() Create an object of the appropriate type to be used as a key.
Text	createValue() Create an object of the appropriate type to be used as a value.
long	getPos() Returns the current position in the input.
float	getProgress() How much of the input has the RecordReader consumed i.e.
boolean	next(MultiFileWordCount.WordOffset key, Text value) Reads the next key/value pair from the input for processing.

从类继承的方法 java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

构造器详细资料

MultiFileWordCount.MultiFileLineRecordReader

public MultiFileWordCount.MultiFileLineRecordReader(Configuration conf,
                                            MultiFileSplit split)
                                             throws IOException

抛出:

IOException

方法详细资料

close

public void close()
           throws IOException

从接口复制的说明: RecordReader

Close this InputSplit to future operations.

指定者:

close 在接口中 RecordReader<MultiFileWordCount.WordOffset,Text>

抛出:

IOException

getPos

public long getPos()
            throws IOException

从接口复制的说明: RecordReader

Returns the current position in the input.

指定者:

getPos 在接口中 RecordReader<MultiFileWordCount.WordOffset,Text>

返回:

the current position in the input.

抛出:

IOException

getProgress

public float getProgress()
                  throws IOException

从接口复制的说明: RecordReader

How much of the input has the RecordReader consumed i.e. has been processed by?

指定者:

getProgress 在接口中 RecordReader<MultiFileWordCount.WordOffset,Text>

返回:

progress from 0.0 to 1.0.

抛出:

IOException

next

public boolean next(MultiFileWordCount.WordOffset key,
           Text value)
             throws IOException

从接口复制的说明: RecordReader

Reads the next key/value pair from the input for processing.

指定者:

next 在接口中 RecordReader<MultiFileWordCount.WordOffset,Text>

参数:

key - the key to read data into

value - the value to read data into

返回:

true iff a key/value was read, false if at EOF

抛出:

IOException

createKey

public MultiFileWordCount.WordOffset createKey()

从接口复制的说明: RecordReader

Create an object of the appropriate type to be used as a key.

指定者:

createKey 在接口中 RecordReader<MultiFileWordCount.WordOffset,Text>

返回:

a new key object.

createValue

public Text createValue()

从接口复制的说明: RecordReader

Create an object of the appropriate type to be used as a value.

指定者:

createValue 在接口中 RecordReader<MultiFileWordCount.WordOffset,Text>

返回:

a new value object.