Skip to content
Open
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Original file line number Diff line number Diff line change
Expand Up @@ -37,8 +37,8 @@ public interface TaskInputOutputContext<KEYIN,VALUEIN,KEYOUT,VALUEOUT>
extends TaskAttemptContext {

/**
* Advance to the next key, value pair, returning null if at end.
* @return the key object that was read into, or null if no more
* Advance to the next key, value pair, returning false if at end.
* @return true if the key object was read, or false if no more
*/
public boolean nextKeyValue() throws IOException, InterruptedException;

Expand All @@ -60,6 +60,8 @@ public interface TaskInputOutputContext<KEYIN,VALUEIN,KEYOUT,VALUEOUT>

/**
* Generate an output key/value pair.
* @param key the key to write
* @param value the value to write
*/
public void write(KEYOUT key, VALUEOUT value)
throws IOException, InterruptedException;
Expand Down