oracle.kv.hadoop.hive.table

Class TableHiveRecordReader

java.lang.Object

oracle.kv.hadoop.hive.table.TableHiveRecordReader

All Implemented Interfaces:

RecordReader<Text,Text>

public class TableHiveRecordReader
extends Object
implements RecordReader<Text,Text>

Concrete implementation of RecordReader; used to read PrimaryKey/Row pairs from an InputSplit.

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 Summary

Constructors

Constructor and Description
TableHiveRecordReader(TableRecordReader v2RecordReader)

Method Summary

Methods

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)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

TableHiveRecordReader

public TableHiveRecordReader(TableRecordReader v2RecordReader)

Method Detail

close

public void close()
           throws IOException

Specified by:

close in interface RecordReader<Text,Text>

Throws:

IOException

getPos

public long getPos()
            throws IOException

Specified by:

getPos in interface RecordReader<Text,Text>

Throws:

IOException

getProgress

public float getProgress()

Specified by:

getProgress in interface RecordReader<Text,Text>

next

public boolean next(Text key,
           Text value)

Specified by:

next in interface RecordReader<Text,Text>

createKey

public Text createKey()

Get the current key.

Specified by:

createKey in interface RecordReader<Text,Text>

Returns:

the current key or null if there is no current key

createValue

public Text createValue()

Get the current value.

Specified by:

createValue in interface RecordReader<Text,Text>

Returns:

the object that was read