org.apache.hadoop.mapred.lib

类 CombineFileRecordReaderWrapper

java.lang.Object

org.apache.hadoop.mapred.lib.CombineFileRecordReaderWrapper

所有已实现的接口：

Closeable, AutoCloseable, RecordReader

@InterfaceAudience.Public
 @InterfaceStability.Stable
public abstract class CombineFileRecordReaderWrapper
extends Object
implements RecordReader

这是一个用于处理单个文件分片的记录读取器包装类。它将大多数方法委托给被包装的实例。具体子类需要提供一个构造函数，使用适当的输入格式调用此父类构造函数。子类构造函数必须满足CombineFileRecordReader所要求的特定构造函数签名。 由于构造函数的要求，需要通过子类化来获得具体的记录读取器包装类。

另请参阅：

CombineFileRecordReader, CombineFileInputFormat

构造函数摘要

修饰符	构造函数和描述
protected	CombineFileRecordReaderWrapper(FileInputFormat<K,V> inputFormat, CombineFileSplit split, Configuration conf, Reporter reporter, Integer idx)

方法摘要

修饰符和类型	方法和描述
void	关闭() Close this InputSplit to future operations.
K	创建密钥() 创建一个适当类型的对象用作键。
V	createValue() 创建一个适当类型的对象作为值使用。
long	getPos() 返回输入中的当前位置。
float	getProgress() How much of the input has the RecordReader consumed i.e.
boolean	next(K key, V value) 从输入中读取下一个键/值对以供处理。

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

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

构造函数详情

CombineFileRecordReaderWrapper

protected CombineFileRecordReaderWrapper(FileInputFormat<K,V> inputFormat,
                                         CombineFileSplit split,
                                         Configuration conf,
                                         Reporter reporter,
                                         Integer idx)
                                  throws IOException

抛出异常:

IOException

方法详情

next

public boolean next(K key,
                    V value)
             throws IOException

从接口复制的描述: RecordReader

从输入中读取下一个键/值对进行处理。

指定者:

next 在接口中 RecordReader<K,V>

参数:

key - 要读取数据的键

value - 要读取数据的值

返回:

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

抛出:

IOException

createKey

public K createKey()

从接口复制的描述: RecordReader

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

指定者:

createKey 在接口中 RecordReader<K,V>

返回:

一个新的键对象。

createValue

public V createValue()

从接口复制的描述: RecordReader

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

指定者:

createValue 在接口中 RecordReader<K,V>

返回:

一个新的值对象。

getPos

public long getPos()
            throws IOException

从接口复制的描述: RecordReader

返回输入中的当前位置。

指定者:

getPos 在接口中 RecordReader<K,V>

返回:

输入中的当前位置。

抛出:

IOException

close

public void close()
           throws IOException

描述复制自接口: RecordReader

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

指定者:

close 在接口 Closeable中

指定者:

close 在接口 AutoCloseable中

指定者:

close 在接口 RecordReader<K,V>中

抛出:

IOException

getProgress

public float getProgress()
                  throws IOException

从接口复制的描述: RecordReader

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

指定者:

getProgress 在接口 RecordReader<K,V>

返回:

进度值，范围从0.0到1.0。

抛出:

IOException