Package 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	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	Description
DelegatingKeyValueScanner(org.apache.hadoop.hbase.regionserver.KeyValueScanner delegate)

Method Summary

Modifier and Type	Method	Description
boolean	backwardSeek(org.apache.hadoop.hbase.ExtendedCell key)
void	close()
void	enforceSeek()
org.apache.hadoop.fs.Path	getFilePath()
org.apache.hadoop.hbase.ExtendedCell	getNextIndexedKey()
long	getScannerOrder()
boolean	isFileScanner()
org.apache.hadoop.hbase.ExtendedCell	next()
org.apache.hadoop.hbase.ExtendedCell	peek()
boolean	realSeekDone()
void	recordBlockSize(IntConsumer blockSizeConsumer)
boolean	requestSeek(org.apache.hadoop.hbase.ExtendedCell kv, boolean forward, boolean useBloom)
boolean	reseek(org.apache.hadoop.hbase.ExtendedCell key)
boolean	seek(org.apache.hadoop.hbase.ExtendedCell key)
boolean	seekToLastRow()
boolean	seekToPreviousRow(org.apache.hadoop.hbase.ExtendedCell 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 Details

delegate

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

Constructor Details

DelegatingKeyValueScanner

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

Method Details

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.ExtendedCell peek()

Specified by:

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

next

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

Specified by:

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

Throws:

IOException

seek

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

Specified by:

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

Throws:

IOException

reseek

public boolean reseek(org.apache.hadoop.hbase.ExtendedCell 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 AutoCloseable

Specified by:

close in interface Closeable

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.ExtendedCell 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.ExtendedCell key)
                     throws IOException

Specified by:

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

Throws:

IOException

seekToPreviousRow

public boolean seekToPreviousRow(org.apache.hadoop.hbase.ExtendedCell 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.ExtendedCell getNextIndexedKey()

Specified by:

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

recordBlockSize

public void recordBlockSize(IntConsumer blockSizeConsumer)

Specified by:

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