org.apache.hadoop.hbase.client

类 ReversedClientScanner

java.lang.Object

org.apache.hadoop.hbase.client.AbstractClientScanner

org.apache.hadoop.hbase.client.ClientScanner

org.apache.hadoop.hbase.client.ReversedClientScanner

所有已实现的接口:

Closeable, AutoCloseable, Iterable<Result>, ResultScanner

直接已知子类:

ClientSmallReversedScanner

@InterfaceAudience.Private
public class ReversedClientScanner
extends ClientScanner

A reversed client scanner which support backward scanning

字段概要

从类继承的字段 org.apache.hadoop.hbase.client.ClientScanner

cache, caching, callable, caller, closed, conf, currentRegion, lastNext, lastResult, maxScannerResultSize, pool, primaryOperationTimeout, rpcControllerFactory, scan, scanMetricsPublished, scannerTimeout

从类继承的字段 org.apache.hadoop.hbase.client.AbstractClientScanner

scanMetrics

构造器概要

构造器

构造器和说明
ReversedClientScanner(org.apache.hadoop.conf.Configuration conf, Scan scan, org.apache.hadoop.hbase.TableName tableName, ClusterConnection connection, RpcRetryingCallerFactory rpcFactory, RpcControllerFactory controllerFactory, ExecutorService pool, int primaryOperationTimeout) Create a new ReversibleClientScanner for the specified table Note that the passed Scan's start row maybe changed.

方法概要

方法

限定符和类型	方法和说明
protected boolean	checkScanStopRow(byte[] startKey)
protected byte[]	createClosestRowBefore(byte[] row) Create the closest row before the specified row
protected org.apache.hadoop.hbase.client.ScannerCallableWithReplicas	getScannerCallable(byte[] localStartKey, int nbRows, byte[] locateStartRow)
protected boolean	nextScanner(int nbRows, boolean done)

从类继承的方法 org.apache.hadoop.hbase.client.ClientScanner

close, getCacheSize, getCaching, getConf, getConnection, getMaxResultSize, getPool, getPrimaryOperationTimeout, getRetries, getScan, getScannerCallable, getScannerTimeout, getTable, getTableName, getTimestamp, initializeScannerInConstruction, loadCache, next, renewLease, writeScanMetrics

从类继承的方法 org.apache.hadoop.hbase.client.AbstractClientScanner

getScanMetrics, initScanMetrics, iterator, next

从类继承的方法 java.lang.Object

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

构造器详细资料

ReversedClientScanner

public ReversedClientScanner(org.apache.hadoop.conf.Configuration conf,
                     Scan scan,
                     org.apache.hadoop.hbase.TableName tableName,
                     ClusterConnection connection,
                     RpcRetryingCallerFactory rpcFactory,
                     RpcControllerFactory controllerFactory,
                     ExecutorService pool,
                     int primaryOperationTimeout)
                      throws IOException

Create a new ReversibleClientScanner for the specified table Note that the passed Scan's start row maybe changed.

参数:

conf -

scan -

tableName -

connection -

pool -

primaryOperationTimeout -

抛出:

IOException

方法详细资料

nextScanner

protected boolean nextScanner(int nbRows,
                  boolean done)
                       throws IOException

覆盖:

nextScanner 在类中 ClientScanner

抛出:

IOException

getScannerCallable

protected org.apache.hadoop.hbase.client.ScannerCallableWithReplicas getScannerCallable(byte[] localStartKey,
                                                                            int nbRows,
                                                                            byte[] locateStartRow)

checkScanStopRow

protected boolean checkScanStopRow(byte[] startKey)

覆盖:

checkScanStopRow 在类中 ClientScanner

createClosestRowBefore

protected byte[] createClosestRowBefore(byte[] row)

Create the closest row before the specified row

参数:

row -

返回:

a new byte array which is the closest front row of the specified one