org.apache.hadoop.mapred

クラス SequenceFileAsTextRecordReader

java.lang.Object

org.apache.hadoop.mapred.SequenceFileAsTextRecordReader

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

RecordReader<Text,Text>

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

This class converts the input keys and values to their String forms by calling toString() method. This class to SequenceFileAsTextInputFormat class is as LineRecordReader class to TextInputFormat class.

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

コンストラクタ

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

メソッドのサマリー

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

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

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

コンストラクタの詳細

SequenceFileAsTextRecordReader

public SequenceFileAsTextRecordReader(Configuration conf,
                                      FileSplit split)
                               throws IOException

例外:

IOException

メソッドの詳細

createKey

public Text createKey()

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

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

定義:

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

戻り値:

a new key object.

createValue

public Text createValue()

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

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

定義:

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

戻り値:

a new value object.

next

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

Read key/value pair in a line.

定義:

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

パラメータ:

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

getProgress

public float getProgress()
                  throws IOException

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

How much of the input has the RecordReader consumed i.e. has been processed by?

定義:

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

戻り値:

progress from 0.0 to 1.0.

例外:

IOException

getPos

public long getPos()
            throws IOException

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

Returns the current position in the input.

定義:

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

戻り値:

the current position in the input.

例外:

IOException

close

public void close()
           throws IOException

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

Close this InputSplit to future operations.

定義:

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

例外:

IOException