public static class InputSplitInputFormat.InputSplitRecordReader<V extends InputSplit>
extends <any>
Constructor and Description |
---|
InputSplitRecordReader() |
Modifier and Type | Method and Description |
---|---|
void |
close() |
NullWritable |
getCurrentKey() |
V |
getCurrentValue() |
float |
getProgress() |
void |
initialize(InputSplit split, TaskAttemptContext context) |
boolean |
nextKeyValue() |
public void close() throws java.io.IOException
java.io.IOException
public NullWritable 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 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
Copyright © 2017 Oracle and/or its affiliates. All Rights Reserved.