public class TableHiveRecordReader extends Object implements RecordReader<Text,Text>
Note that this RecordReader is based on version 1 of MapReduce (as required by the Hive infrastructure), but wraps and delegates to a YARN based (MapReduce version 2) RecordReader. This is done because the RecordReader provided by Oracle NoSQL Database to support Hadoop integration is YARN based, and this class wishes to exploit and reuse the functionality already provided by the YARN based RecordReader class.
Constructor and Description |
---|
TableHiveRecordReader(JobConf jobConf,
TableRecordReader v2RecordReader) |
Modifier and Type | Method and Description |
---|---|
void |
close() |
Text |
createKey()
Get the current key.
|
Text |
createValue()
Get the current value.
|
long |
getPos() |
float |
getProgress() |
boolean |
next(Text key,
Text value) |
public TableHiveRecordReader(JobConf jobConf, TableRecordReader v2RecordReader)
public void close() throws IOException
close
in interface RecordReader<Text,Text>
IOException
public long getPos() throws IOException
getPos
in interface RecordReader<Text,Text>
IOException
public float getProgress()
getProgress
in interface RecordReader<Text,Text>
public boolean next(Text key, Text value) throws IOException
next
in interface RecordReader<Text,Text>
IOException
public Text createKey()
createKey
in interface RecordReader<Text,Text>
public Text createValue()
createValue
in interface RecordReader<Text,Text>
Copyright (c) 2011, 2017 Oracle and/or its affiliates. All rights reserved.