public static class IntegrationTestBulkLoad.FixedRecordReader<K,V>
extends <any>
Constructor and Description |
---|
FixedRecordReader(K[] keys,
V[] values) |
Modifier and Type | Method and Description |
---|---|
void |
close() |
K |
getCurrentKey() |
V |
getCurrentValue() |
float |
getProgress() |
void |
initialize(InputSplit split,
TaskAttemptContext context) |
boolean |
nextKeyValue() |
public void initialize(InputSplit split, TaskAttemptContext context) throws java.io.IOException, java.lang.InterruptedException
java.io.IOException
java.lang.InterruptedException
public boolean nextKeyValue() throws java.io.IOException, java.lang.InterruptedException
java.io.IOException
java.lang.InterruptedException
public K getCurrentKey() throws java.io.IOException, java.lang.InterruptedException
java.io.IOException
java.lang.InterruptedException
public V getCurrentValue() throws java.io.IOException, java.lang.InterruptedException
java.io.IOException
java.lang.InterruptedException
public float getProgress() throws java.io.IOException, java.lang.InterruptedException
java.io.IOException
java.lang.InterruptedException
public void close() throws java.io.IOException
java.io.IOException