org.apache.hadoop.mapred

类 KeyValueLineRecordReader

java.lang.Object

org.apache.hadoop.mapred.KeyValueLineRecordReader

所有已实现的接口：

Closeable, AutoCloseable, RecordReader<Text,Text>

@InterfaceAudience.Public
 @InterfaceStability.Stable
public class KeyValueLineRecordReader
extends Object
implements RecordReader<Text,Text>

该类将输入中的每一行视为由分隔符分隔的键/值对。分隔符可在配置文件中通过属性名mapreduce.input.keyvaluelinerecordreader.key.value.separator指定。默认分隔符是制表符('\t')。

构造函数摘要

构造函数及描述
KeyValueLineRecordReader(Configuration job, FileSplit split)

方法摘要

修饰符和类型	方法和描述
void	关闭() Close this InputSplit to future operations.
Text	创建密钥() 创建一个适当类型的对象用作键。
Text	createValue() 创建一个适当类型的对象作为值使用。
static int	findSeparator(byte[] utf, int start, int length, byte sep)
类	getKeyClass()
long	getPos() 返回输入中的当前位置。
float	getProgress() How much of the input has the RecordReader consumed i.e.
boolean	next(Text key, Text value) 读取一行中的键/值对。

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

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

构造函数详情

KeyValueLineRecordReader

public KeyValueLineRecordReader(Configuration job,
                                FileSplit split)
                         throws IOException

抛出异常：

IOException

方法详情

getKeyClass

public Class getKeyClass()

createKey

public Text createKey()

从接口复制的描述: RecordReader

创建一个适当类型的对象作为键使用。

指定者:

createKey 在接口中 RecordReader<Text,Text>

返回:

一个新的键对象。

createValue

public Text createValue()

从接口复制的描述: RecordReader

创建一个适当类型的对象作为值使用。

指定者:

createValue 在接口中 RecordReader<Text,Text>

返回:

一个新的值对象。

findSeparator

public static int findSeparator(byte[] utf,
                                int start,
                                int length,
                                byte sep)

next

public boolean next(Text key,
                    Text value)
             throws IOException

读取一行中的键/值对。

指定者：

next 在接口 RecordReader<Text,Text>中

参数：

key - 要读取数据的键

value - 要读取数据的值

返回：

如果读取到键/值对返回true，如果到达文件末尾返回false

抛出：

IOException

getProgress

public float getProgress()
                  throws IOException

从接口复制的描述: RecordReader

RecordReader已消耗了多少输入数据，即已被处理的部分。

指定者:

getProgress 在接口中 RecordReader<Text,Text>

返回:

进度值，范围从0.0到1.0。

抛出:

IOException

getPos

public long getPos()
            throws IOException

从接口复制的描述: RecordReader

返回输入中的当前位置。

指定者:

getPos 在接口 RecordReader<Text,Text>

返回:

输入中的当前位置。

抛出:

IOException

close

public void close()
           throws IOException

从接口复制的描述: RecordReader

关闭此InputSplit以禁止后续操作。

指定者:

close 在接口 Closeable

指定者:

close 在接口 AutoCloseable

指定者:

close 在接口 RecordReader<Text,Text>

抛出:

IOException