Uses of Interface
co.cask.cdap.data2.transaction.queue.QueueScanner

Packages that use QueueScanner

Package	Description
co.cask.cdap.data2.transaction.queue	Transaction aware queue implementation.
co.cask.cdap.data2.transaction.queue.hbase	This package contains an HBase implementation of queues.
co.cask.cdap.data2.transaction.queue.leveldb	This package contains levelDB implementation of queues.

Uses of QueueScanner in co.cask.cdap.data2.transaction.queue

Fields in co.cask.cdap.data2.transaction.queue declared as QueueScanner

Modifier and Type	Field and Description
static QueueScanner	QueueScanner.EMPTY

Methods in co.cask.cdap.data2.transaction.queue that return QueueScanner

Modifier and Type	Method and Description
protected abstract QueueScanner	AbstractQueueConsumer.getScanner(byte[] startRow, byte[] stopRow, int numRows)

Uses of QueueScanner in co.cask.cdap.data2.transaction.queue.hbase

Methods in co.cask.cdap.data2.transaction.queue.hbase that return QueueScanner

Modifier and Type	Method and Description
QueueScanner	SaltedHBaseQueueStrategy.createScanner(ConsumerConfig consumerConfig, org.apache.hadoop.hbase.client.HTable hTable, org.apache.hadoop.hbase.client.Scan scan, int numRows)
QueueScanner	ShardedHBaseQueueStrategy.createScanner(ConsumerConfig consumerConfig, org.apache.hadoop.hbase.client.HTable hTable, org.apache.hadoop.hbase.client.Scan scan, int numRows)
QueueScanner	HBaseQueueStrategy.createScanner(ConsumerConfig consumerConfig, org.apache.hadoop.hbase.client.HTable hTable, org.apache.hadoop.hbase.client.Scan scan, int numRows) Creates a QueueScanner from the given Scan on the HBase table.

Uses of QueueScanner in co.cask.cdap.data2.transaction.queue.leveldb

Methods in co.cask.cdap.data2.transaction.queue.leveldb that return QueueScanner

Modifier and Type	Method and Description
protected QueueScanner	LevelDBQueueConsumer.getScanner(byte[] startRow, byte[] stopRow, int numRows)