co.cask.cdap.hbase.wd

Class DistributedScanner

java.lang.Object

co.cask.cdap.hbase.wd.DistributedScanner

All Implemented Interfaces:

Closeable, AutoCloseable, Iterable<org.apache.hadoop.hbase.client.Result>, org.apache.hadoop.hbase.client.ResultScanner

public class DistributedScanner
extends Object
implements org.apache.hadoop.hbase.client.ResultScanner

Interface for client-side scanning the data written with keys distribution

Method Summary

Methods

Modifier and Type	Method and Description
void	close()
static DistributedScanner	create(org.apache.hadoop.hbase.client.HTableInterface hTable, org.apache.hadoop.hbase.client.Scan originalScan, AbstractRowKeyDistributor keyDistributor, ExecutorService scansExecutor)
Iterator<org.apache.hadoop.hbase.client.Result>	iterator()
org.apache.hadoop.hbase.client.Result	next()
org.apache.hadoop.hbase.client.Result[]	next(int nbRows)

Methods inherited from class java.lang.Object

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

Method Detail

next

public org.apache.hadoop.hbase.client.Result next()
                                           throws IOException

Specified by:

next in interface org.apache.hadoop.hbase.client.ResultScanner

Throws:

IOException

next

public org.apache.hadoop.hbase.client.Result[] next(int nbRows)
                                             throws IOException

Specified by:

next in interface org.apache.hadoop.hbase.client.ResultScanner

Throws:

IOException

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.client.ResultScanner

create

public static DistributedScanner create(org.apache.hadoop.hbase.client.HTableInterface hTable,
                        org.apache.hadoop.hbase.client.Scan originalScan,
                        AbstractRowKeyDistributor keyDistributor,
                        ExecutorService scansExecutor)
                                 throws IOException

Throws:

IOException

iterator

public Iterator<org.apache.hadoop.hbase.client.Result> iterator()

Specified by:

iterator in interface Iterable<org.apache.hadoop.hbase.client.Result>