public class NoSQLRecordReader
extends <any>
Constructor and Description |
---|
NoSQLRecordReader() |
Modifier and Type | Method and Description |
---|---|
void |
close() |
Text |
getCurrentKey() |
RecordInfo |
getCurrentValue() |
float |
getProgress() |
void |
initialize(InputSplit split, TaskAttemptContext context) |
boolean |
nextKeyValue() |
public void close() throws java.io.IOException
java.io.IOException
public Text getCurrentKey() throws java.io.IOException, java.lang.InterruptedException
java.io.IOException
java.lang.InterruptedException
public RecordInfo 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.