com.nhncorp.neptune.parallel.hadoop
Class AbstractTabletInputFormat.TabletColumnRecordReader

java.lang.Object
  com.nhncorp.neptune.parallel.hadoop.AbstractTabletInputFormat.TabletColumnRecordReader

All Implemented Interfaces:

org.apache.hadoop.mapred.RecordReader<Row.Key,ScanCell>

Enclosing class:

AbstractTabletInputFormat

public static class AbstractTabletInputFormat.TabletColumnRecordReader
extends java.lang.Object
implements org.apache.hadoop.mapred.RecordReader<Row.Key,ScanCell>

Constructor Summary

AbstractTabletInputFormat.TabletColumnRecordReader(NConfiguration conf, java.lang.String tableName, RowFilter rowFilter)

Method Summary

void	close()
Row.Key	createKey()
ScanCell	createValue()
long	getPos()
float	getProgress()
boolean	next(Row.Key key, ScanCell value)

Methods inherited from class java.lang.Object

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

Constructor Detail

AbstractTabletInputFormat.TabletColumnRecordReader

public AbstractTabletInputFormat.TabletColumnRecordReader(NConfiguration conf,
                                                          java.lang.String tableName,
                                                          RowFilter rowFilter)
                                                   throws java.io.IOException

Throws:

java.io.IOException

Method Detail

close

public void close()
           throws java.io.IOException

Specified by:

close in interface org.apache.hadoop.mapred.RecordReader<Row.Key,ScanCell>

Throws:

java.io.IOException

createKey

public Row.Key createKey()

Specified by:

createKey in interface org.apache.hadoop.mapred.RecordReader<Row.Key,ScanCell>

createValue

public ScanCell createValue()

Specified by:

createValue in interface org.apache.hadoop.mapred.RecordReader<Row.Key,ScanCell>

getPos

public long getPos()

Specified by:

getPos in interface org.apache.hadoop.mapred.RecordReader<Row.Key,ScanCell>

getProgress

public float getProgress()

Specified by:

getProgress in interface org.apache.hadoop.mapred.RecordReader<Row.Key,ScanCell>

next

public boolean next(Row.Key key,
                    ScanCell value)
             throws java.io.IOException

Specified by:

next in interface org.apache.hadoop.mapred.RecordReader<Row.Key,ScanCell>

Throws:

java.io.IOException