org.apache.hadoop.mapred

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

既知のサブインタフェースのリスト:

ComposableRecordReader<K,V>

既知の実装クラスのリスト:

CombineFileRecordReader, CombineFileRecordReaderWrapper, InnerJoinRecordReader, JoinRecordReader, KeyValueLineRecordReader, MultiFilterRecordReader, OuterJoinRecordReader, OverrideRecordReader, SequenceFileAsTextRecordReader, SequenceFileRecordReader, WrappedRecordReader

@InterfaceAudience.Public
 @InterfaceStability.Stable
public interface RecordReader<K,V>

RecordReader reads <key, value> pairs from an InputSplit.

RecordReader, typically, converts the byte-oriented view of the input, provided by the InputSplit, and presents a record-oriented view for the Mapper and Reducer tasks for processing. It thus assumes the responsibility of processing record boundaries and presenting the tasks with keys and values.

関連項目:

InputSplit, InputFormat

メソッドのサマリー

修飾子とタイプ	メソッドと説明
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.

メソッドの詳細

next

boolean next(K key,
             V value)
      throws IOException

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

パラメータ:

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

K createKey()

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

戻り値:

a new key object.

createValue

V createValue()

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

戻り値:

a new value object.

getPos

long getPos()
     throws IOException

Returns the current position in the input.

戻り値:

the current position in the input.

例外:

IOException

close

void close()
    throws IOException

Close this InputSplit to future operations.

例外:

IOException

getProgress

float getProgress()
           throws IOException

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

戻り値:

progress from 0.0 to 1.0.

例外:

IOException