org.apache.hadoop.mapred.lib

クラス CombineFileRecordReaderWrapper<K,V>

java.lang.Object

org.apache.hadoop.mapred.lib.CombineFileRecordReaderWrapper<K,V>

すべての実装されたインタフェース:

RecordReader<K,V>

@InterfaceAudience.Public
 @InterfaceStability.Stable
public abstract class CombineFileRecordReaderWrapper<K,V>
extends Object
implements RecordReader<K,V>

A wrapper class for a record reader that handles a single file split. It delegates most of the methods to the wrapped instance. A concrete subclass needs to provide a constructor that calls this parent constructor with the appropriate input format. The subclass constructor must satisfy the specific constructor signature that is required by CombineFileRecordReader. Subclassing is needed to get a concrete record reader wrapper because of the constructor requirement.

関連項目:

CombineFileRecordReader, CombineFileInputFormat

コンストラクタのサマリー

コンストラクタ

修飾子	コンストラクタと説明
protected	CombineFileRecordReaderWrapper(FileInputFormat<K,V> inputFormat, CombineFileSplit split, Configuration conf, Reporter reporter, Integer idx)

メソッドのサマリー

修飾子とタイプ	メソッドと説明
void	close() Close this InputSplit to future operations.
K	createKey() Create an object of the appropriate type to be used as a key.
V	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(K key, V 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

コンストラクタの詳細

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

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

定義:

next インタフェース内 RecordReader<K,V>

パラメータ:

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 K createKey()

インタフェースからコピーされた説明: RecordReader

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

定義:

createKey インタフェース内 RecordReader<K,V>

戻り値:

a new key object.

createValue

public V createValue()

インタフェースからコピーされた説明: RecordReader

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

定義:

createValue インタフェース内 RecordReader<K,V>

戻り値:

a new value object.

getPos

public long getPos()
            throws IOException

インタフェースからコピーされた説明: RecordReader

Returns the current position in the input.

定義:

getPos インタフェース内 RecordReader<K,V>

戻り値:

the current position in the input.

例外:

IOException

close

public void close()
           throws IOException

インタフェースからコピーされた説明: RecordReader

Close this InputSplit to future operations.

定義:

close インタフェース内 RecordReader<K,V>

例外:

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<K,V>

戻り値:

progress from 0.0 to 1.0.

例外:

IOException