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 IOException, InterruptedException
IOException
InterruptedException
public boolean nextKeyValue() throws IOException, InterruptedException
IOException
InterruptedException
public K getCurrentKey() throws IOException, InterruptedException
IOException
InterruptedException
public V getCurrentValue() throws IOException, InterruptedException
IOException
InterruptedException
public float getProgress() throws IOException, InterruptedException
IOException
InterruptedException
public void close() throws IOException
IOException