KEYIN
- VALUEIN
- @InterfaceAudience.Public @InterfaceStability.Stable public abstract class RecordReader<KEYIN,VALUEIN> extends Object implements Closeable
Mapper
.Constructor and Description |
---|
RecordReader() |
Modifier and Type | Method and Description |
---|---|
abstract void |
close()
Close the record reader.
|
abstract KEYIN |
getCurrentKey()
Get the current key
|
abstract VALUEIN |
getCurrentValue()
Get the current value.
|
abstract float |
getProgress()
The current progress of the record reader through its data.
|
abstract void |
initialize(InputSplit split,
TaskAttemptContext context)
Called once at initialization.
|
abstract boolean |
nextKeyValue()
Read the next key, value pair.
|
public abstract void initialize(InputSplit split, TaskAttemptContext context) throws IOException, InterruptedException
split
- the split that defines the range of records to readcontext
- the information about the taskIOException
InterruptedException
public abstract boolean nextKeyValue() throws IOException, InterruptedException
IOException
InterruptedException
public abstract KEYIN getCurrentKey() throws IOException, InterruptedException
IOException
InterruptedException
public abstract VALUEIN getCurrentValue() throws IOException, InterruptedException
IOException
InterruptedException
public abstract float getProgress() throws IOException, InterruptedException
IOException
InterruptedException
public abstract void close() throws IOException
close
in interface Closeable
close
in interface AutoCloseable
IOException
Copyright © 2023 Apache Software Foundation. All rights reserved.