org.apache.hadoop.mapred

クラス SequenceFileRecordReader<K,V>

java.lang.Object

org.apache.hadoop.mapred.SequenceFileRecordReader<K,V>

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

RecordReader<K,V>

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

An RecordReader for SequenceFiles.

フィールドのサマリー

フィールド

修飾子とタイプ	フィールドと説明
protected Configuration	conf

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

コンストラクタ

コンストラクタと説明
SequenceFileRecordReader(Configuration conf, FileSplit split)

メソッドのサマリー

修飾子とタイプ	メソッドと説明
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.
protected void	getCurrentValue(V value)
Class	getKeyClass() The class of key that must be passed to next(Object, Object)..
long	getPos() Returns the current position in the input.
float	getProgress() Return the progress within the input split
Class	getValueClass() The class of value that must be passed to next(Object, Object)..
protected boolean	next(K key)
boolean	next(K key, V value) Reads the next key/value pair from the input for processing.
protected void	seek(long pos)

クラスから継承されたメソッド java.lang.Object

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

フィールドの詳細

conf

protected Configuration conf

コンストラクタの詳細

SequenceFileRecordReader

public SequenceFileRecordReader(Configuration conf,
                                FileSplit split)
                         throws IOException

例外:

IOException

メソッドの詳細

getKeyClass

public Class getKeyClass()

The class of key that must be passed to next(Object, Object)..

getValueClass

public Class getValueClass()

The class of value that must be passed to next(Object, Object)..

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.

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

next

protected boolean next(K key)
                throws IOException

例外:

IOException

getCurrentValue

protected void getCurrentValue(V value)
                        throws IOException

例外:

IOException

getProgress

public float getProgress()
                  throws IOException

Return the progress within the input split

定義:

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

戻り値:

0.0 to 1.0 of the input byte range

例外:

IOException

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

seek

protected void seek(long pos)
             throws IOException

例外:

IOException

close

public void close()
           throws IOException

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

Close this InputSplit to future operations.

定義:

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

例外:

IOException