org.apache.hadoop.hive.accumulo.mr

Class HiveAccumuloRecordReader

java.lang.Object

org.apache.hadoop.hive.accumulo.mr.HiveAccumuloRecordReader

All Implemented Interfaces:

org.apache.hadoop.mapred.RecordReader<org.apache.hadoop.io.Text,AccumuloHiveRow>

public class HiveAccumuloRecordReader
extends Object
implements org.apache.hadoop.mapred.RecordReader<org.apache.hadoop.io.Text,AccumuloHiveRow>

Translate the Key Value pairs from AccumuloInputFormat to a Writable for consumption by the AccumuloSerDe.

Constructor Summary

Constructors

Constructor and Description
HiveAccumuloRecordReader(org.apache.hadoop.mapred.RecordReader<org.apache.hadoop.io.Text,org.apache.accumulo.core.util.PeekingIterator<Map.Entry<org.apache.accumulo.core.data.Key,org.apache.accumulo.core.data.Value>>> recordReader, int iteratorCount)

Method Summary

Methods

Modifier and Type	Method and Description
void	close()
org.apache.hadoop.io.Text	createKey()
AccumuloHiveRow	createValue()
long	getPos()
float	getProgress()
boolean	next(org.apache.hadoop.io.Text rowKey, AccumuloHiveRow row)

Methods inherited from class java.lang.Object

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

Constructor Detail

HiveAccumuloRecordReader

public HiveAccumuloRecordReader(org.apache.hadoop.mapred.RecordReader<org.apache.hadoop.io.Text,org.apache.accumulo.core.util.PeekingIterator<Map.Entry<org.apache.accumulo.core.data.Key,org.apache.accumulo.core.data.Value>>> recordReader,
                        int iteratorCount)

Method Detail

close

public void close()
           throws IOException

Specified by:

close in interface org.apache.hadoop.mapred.RecordReader<org.apache.hadoop.io.Text,AccumuloHiveRow>

Throws:

IOException

createKey

public org.apache.hadoop.io.Text createKey()

Specified by:

createKey in interface org.apache.hadoop.mapred.RecordReader<org.apache.hadoop.io.Text,AccumuloHiveRow>

createValue

public AccumuloHiveRow createValue()

Specified by:

createValue in interface org.apache.hadoop.mapred.RecordReader<org.apache.hadoop.io.Text,AccumuloHiveRow>

getPos

public long getPos()
            throws IOException

Specified by:

getPos in interface org.apache.hadoop.mapred.RecordReader<org.apache.hadoop.io.Text,AccumuloHiveRow>

Throws:

IOException

getProgress

public float getProgress()
                  throws IOException

Specified by:

getProgress in interface org.apache.hadoop.mapred.RecordReader<org.apache.hadoop.io.Text,AccumuloHiveRow>

Throws:

IOException

next

public boolean next(org.apache.hadoop.io.Text rowKey,
           AccumuloHiveRow row)
             throws IOException

Specified by:

next in interface org.apache.hadoop.mapred.RecordReader<org.apache.hadoop.io.Text,AccumuloHiveRow>

Throws:

IOException