org.apache.hadoop.contrib.index.example

类 LineDocRecordReader

java.lang.Object

org.apache.hadoop.contrib.index.example.LineDocRecordReader

所有已实现的接口:

RecordReader<DocumentID,LineDocTextAndOp>

public class LineDocRecordReader
extends Object
implements RecordReader<DocumentID,LineDocTextAndOp>

A simple RecordReader for LineDoc for plain text files where each line is a doc. Each line is as follows: documentIDopcontent, where op can be "i", "ins" or "insert" for insert, "d", "del" or "delete" for delete, or "u", "upd" or "update" for update.

构造器概要

构造器

构造器和说明
LineDocRecordReader(Configuration job, FileSplit split) Constructor

方法概要

方法

限定符和类型	方法和说明
void	close() Close this InputSplit to future operations.
DocumentID	createKey() Create an object of the appropriate type to be used as a key.
LineDocTextAndOp	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(DocumentID key, LineDocTextAndOp 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

构造器详细资料

LineDocRecordReader

public LineDocRecordReader(Configuration job,
                   FileSplit split)
                    throws IOException

Constructor

参数:

job -

split -

抛出:

IOException

方法详细资料

close

public void close()
           throws IOException

从接口复制的说明: RecordReader

Close this InputSplit to future operations.

指定者:

close 在接口中 RecordReader<DocumentID,LineDocTextAndOp>

抛出:

IOException

createKey

public DocumentID createKey()

从接口复制的说明: RecordReader

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

指定者:

createKey 在接口中 RecordReader<DocumentID,LineDocTextAndOp>

返回:

a new key object.

createValue

public LineDocTextAndOp createValue()

从接口复制的说明: RecordReader

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

指定者:

createValue 在接口中 RecordReader<DocumentID,LineDocTextAndOp>

返回:

a new value object.

getPos

public long getPos()
            throws IOException

从接口复制的说明: RecordReader

Returns the current position in the input.

指定者:

getPos 在接口中 RecordReader<DocumentID,LineDocTextAndOp>

返回:

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<DocumentID,LineDocTextAndOp>

返回:

progress from 0.0 to 1.0.

抛出:

IOException

next

public boolean next(DocumentID key,
           LineDocTextAndOp value)
             throws IOException

从接口复制的说明: RecordReader

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

指定者:

next 在接口中 RecordReader<DocumentID,LineDocTextAndOp>

参数:

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