org.apache.hadoop.hbase.regionserver

Class DelegatingKeyValueScanner

java.lang.Object

org.apache.hadoop.hbase.regionserver.DelegatingKeyValueScanner

All Implemented Interfaces:

Closeable, AutoCloseable, org.apache.hadoop.hbase.regionserver.KeyValueScanner, org.apache.hadoop.hbase.regionserver.Shipper

public class DelegatingKeyValueScanner
extends Object
implements org.apache.hadoop.hbase.regionserver.KeyValueScanner

Field Summary

Fields

Modifier and Type	Field and Description
protected org.apache.hadoop.hbase.regionserver.KeyValueScanner	delegate

Fields inherited from interface org.apache.hadoop.hbase.regionserver.KeyValueScanner

NO_NEXT_INDEXED_KEY

Constructor Summary

Constructors

Constructor and Description
DelegatingKeyValueScanner(org.apache.hadoop.hbase.regionserver.KeyValueScanner delegate)

Method Summary

Modifier and Type	Method and Description
boolean	backwardSeek(org.apache.hadoop.hbase.Cell key)
void	close()
void	enforceSeek()
org.apache.hadoop.fs.Path	getFilePath()
org.apache.hadoop.hbase.Cell	getNextIndexedKey()
long	getScannerOrder()
boolean	isFileScanner()
org.apache.hadoop.hbase.Cell	next()
org.apache.hadoop.hbase.Cell	peek()
boolean	realSeekDone()
boolean	requestSeek(org.apache.hadoop.hbase.Cell kv, boolean forward, boolean useBloom)
boolean	reseek(org.apache.hadoop.hbase.Cell key)
boolean	seek(org.apache.hadoop.hbase.Cell key)
boolean	seekToLastRow()
boolean	seekToPreviousRow(org.apache.hadoop.hbase.Cell key)
void	shipped()
boolean	shouldUseScanner(org.apache.hadoop.hbase.client.Scan scan, org.apache.hadoop.hbase.regionserver.HStore store, long oldestUnexpiredTS)

Methods inherited from class java.lang.Object

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

Field Detail

delegate

protected org.apache.hadoop.hbase.regionserver.KeyValueScanner delegate

Constructor Detail

DelegatingKeyValueScanner

public DelegatingKeyValueScanner(org.apache.hadoop.hbase.regionserver.KeyValueScanner delegate)

Method Detail

shipped

public void shipped()
             throws IOException

Specified by:

shipped in interface org.apache.hadoop.hbase.regionserver.Shipper

Throws:

IOException

peek

public org.apache.hadoop.hbase.Cell peek()

Specified by:

peek in interface org.apache.hadoop.hbase.regionserver.KeyValueScanner

next

public org.apache.hadoop.hbase.Cell next()
                                  throws IOException

Specified by:

next in interface org.apache.hadoop.hbase.regionserver.KeyValueScanner

Throws:

IOException

seek

public boolean seek(org.apache.hadoop.hbase.Cell key)
             throws IOException

Specified by:

seek in interface org.apache.hadoop.hbase.regionserver.KeyValueScanner

Throws:

IOException

reseek

public boolean reseek(org.apache.hadoop.hbase.Cell key)
               throws IOException

Specified by:

reseek in interface org.apache.hadoop.hbase.regionserver.KeyValueScanner

Throws:

IOException

getScannerOrder

public long getScannerOrder()

Specified by:

getScannerOrder in interface org.apache.hadoop.hbase.regionserver.KeyValueScanner

close

public void close()

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

Specified by:

close in interface org.apache.hadoop.hbase.regionserver.KeyValueScanner

shouldUseScanner

public boolean shouldUseScanner(org.apache.hadoop.hbase.client.Scan scan,
                                org.apache.hadoop.hbase.regionserver.HStore store,
                                long oldestUnexpiredTS)

Specified by:

shouldUseScanner in interface org.apache.hadoop.hbase.regionserver.KeyValueScanner

requestSeek

public boolean requestSeek(org.apache.hadoop.hbase.Cell kv,
                           boolean forward,
                           boolean useBloom)
                    throws IOException

Specified by:

requestSeek in interface org.apache.hadoop.hbase.regionserver.KeyValueScanner

Throws:

IOException

realSeekDone

public boolean realSeekDone()

Specified by:

realSeekDone in interface org.apache.hadoop.hbase.regionserver.KeyValueScanner

enforceSeek

public void enforceSeek()
                 throws IOException

Specified by:

enforceSeek in interface org.apache.hadoop.hbase.regionserver.KeyValueScanner

Throws:

IOException

isFileScanner

public boolean isFileScanner()

Specified by:

isFileScanner in interface org.apache.hadoop.hbase.regionserver.KeyValueScanner

getFilePath

public org.apache.hadoop.fs.Path getFilePath()

Specified by:

getFilePath in interface org.apache.hadoop.hbase.regionserver.KeyValueScanner

backwardSeek

public boolean backwardSeek(org.apache.hadoop.hbase.Cell key)
                     throws IOException

Specified by:

backwardSeek in interface org.apache.hadoop.hbase.regionserver.KeyValueScanner

Throws:

IOException

seekToPreviousRow

public boolean seekToPreviousRow(org.apache.hadoop.hbase.Cell key)
                          throws IOException

Specified by:

seekToPreviousRow in interface org.apache.hadoop.hbase.regionserver.KeyValueScanner

Throws:

IOException

seekToLastRow

public boolean seekToLastRow()
                      throws IOException

Specified by:

seekToLastRow in interface org.apache.hadoop.hbase.regionserver.KeyValueScanner

Throws:

IOException

getNextIndexedKey

public org.apache.hadoop.hbase.Cell getNextIndexedKey()

Specified by:

getNextIndexedKey in interface org.apache.hadoop.hbase.regionserver.KeyValueScanner