org.apache.hadoop.mapred

クラス KeyValueLineRecordReader

java.lang.Object

org.apache.hadoop.mapred.KeyValueLineRecordReader

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

RecordReader<Text,Text>

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

This class treats a line in the input as a key/value pair separated by a separator character. The separator can be specified in config file under the attribute name mapreduce.input.keyvaluelinerecordreader.key.value.separator. The default separator is the tab character ('\t').

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

コンストラクタ

コンストラクタと説明
KeyValueLineRecordReader(Configuration job, 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.
static int	findSeparator(byte[] utf, int start, int length, byte sep)
Class	getKeyClass()
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

コンストラクタの詳細

KeyValueLineRecordReader

public KeyValueLineRecordReader(Configuration job,
                                FileSplit split)
                         throws IOException

例外:

IOException

メソッドの詳細

getKeyClass

public Class getKeyClass()

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.

findSeparator

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

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