org.apache.hadoop.hbase.thrift2.client

Class ThriftTable.Scanner

java.lang.Object

org.apache.hadoop.hbase.thrift2.client.ThriftTable.Scanner

All Implemented Interfaces:

Closeable, AutoCloseable, Iterable<Result>, ResultScanner

Enclosing class:

ThriftTable

private class ThriftTable.Scanner
extends Object
implements ResultScanner

A scanner to perform scan from thrift server getScannerResults is used in this scanner

Field Summary

Fields

Modifier and Type	Field and Description
protected Queue<Result>	cache
protected Result	lastResult
protected org.apache.hadoop.hbase.thrift2.generated.TScan	scan

Constructor Summary

Constructors

Constructor and Description
Scanner(Scan scan)

Method Summary

Modifier and Type	Method and Description
void	close() Closes the scanner and releases any resources it has allocated
protected byte[]	createClosestRowAfter(byte[] row) Create the closest row after the specified row
ScanMetrics	getScanMetrics() Returns the scan metrics, or null if we do not enable metrics.
Result	next() Grab the next row's worth of values.
boolean	renewLease() Allow the client to renew the scanner's lease on the server.
private void	setupNextScanner()

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.hadoop.hbase.client.ResultScanner

iterator, next

Methods inherited from interface java.lang.Iterable

forEach, spliterator

Field Detail

scan

protected org.apache.hadoop.hbase.thrift2.generated.TScan scan

lastResult

protected Result lastResult

cache

protected final Queue<Result> cache

Constructor Detail

Scanner

public Scanner(Scan scan)
        throws IOException

Throws:

IOException

Method Detail

next

public Result next()
            throws IOException

Description copied from interface: ResultScanner

Grab the next row's worth of values. The scanner will return a Result.

Specified by:

next in interface ResultScanner

Returns:

Result object if there is another row, null if the scanner is exhausted.

Throws:

IOException - e

close

public void close()

Description copied from interface: ResultScanner

Closes the scanner and releases any resources it has allocated

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

Specified by:

close in interface ResultScanner

renewLease

public boolean renewLease()

Description copied from interface: ResultScanner

Allow the client to renew the scanner's lease on the server.

Specified by:

renewLease in interface ResultScanner

Returns:

true if the lease was successfully renewed, false otherwise.

getScanMetrics

public ScanMetrics getScanMetrics()

Description copied from interface: ResultScanner

Returns the scan metrics, or null if we do not enable metrics.

Specified by:

getScanMetrics in interface ResultScanner

setupNextScanner

private void setupNextScanner()

createClosestRowAfter

protected byte[] createClosestRowAfter(byte[] row)

Create the closest row after the specified row