A B C D E F G H I L M P R S T U W

A

abort(String, Throwable) - Method in class co.cask.cdap.data2.util.hbase.MockRegionServerServices

addToOnlineRegions(HRegion) - Method in class co.cask.cdap.data2.util.hbase.MockRegionServerServices

B

buildHTableDescriptor(TableId) - Method in class co.cask.cdap.data2.util.hbase.HBase98TableUtil

buildHTableDescriptor(HTableDescriptor) - Method in class co.cask.cdap.data2.util.hbase.HBase98TableUtil

C

co.cask.cdap.data2.increment.hbase98 - package co.cask.cdap.data2.increment.hbase98

co.cask.cdap.data2.transaction.coprocessor.hbase98 - package co.cask.cdap.data2.transaction.coprocessor.hbase98

co.cask.cdap.data2.transaction.queue.coprocessor.hbase98 - package co.cask.cdap.data2.transaction.queue.coprocessor.hbase98

co.cask.cdap.data2.transaction.queue.hbase - package co.cask.cdap.data2.transaction.queue.hbase

co.cask.cdap.data2.util.hbase - package co.cask.cdap.data2.util.hbase

combine(Filter, Filter) - Static method in class co.cask.cdap.data2.increment.hbase98.Filters

Adds overrideFilter on to baseFilter, if it exists, otherwise replaces it.

createHTable(Configuration, TableId) - Method in class co.cask.cdap.data2.util.hbase.HBase98TableUtil

createNamespaceIfNotExists(HBaseAdmin, String) - Method in class co.cask.cdap.data2.util.hbase.HBase98TableUtil

D

DefaultTransactionProcessor - Class in co.cask.cdap.data2.transaction.coprocessor.hbase98

Implementation of the TransactionProcessor coprocessor that uses DefaultTransactionStateCache to automatically refresh transaction state.

DefaultTransactionProcessor() - Constructor for class co.cask.cdap.data2.transaction.coprocessor.hbase98.DefaultTransactionProcessor

deleteNamespaceIfExists(HBaseAdmin, String) - Method in class co.cask.cdap.data2.util.hbase.HBase98TableUtil

deleteTable(HBaseAdmin, TableId) - Method in class co.cask.cdap.data2.util.hbase.HBase98TableUtil

DequeueFilter - Class in co.cask.cdap.data2.transaction.queue.coprocessor.hbase98

Server-side filter for dequeue operation

DequeueFilter(ConsumerConfig, Transaction) - Constructor for class co.cask.cdap.data2.transaction.queue.coprocessor.hbase98.DequeueFilter

DequeueScanObserver - Class in co.cask.cdap.data2.transaction.queue.coprocessor.hbase98

DequeueScanObserver() - Constructor for class co.cask.cdap.data2.transaction.queue.coprocessor.hbase98.DequeueScanObserver

determineReturnCode(Filter.ReturnCode, Filter.ReturnCode) - Method in class co.cask.cdap.data2.increment.hbase98.IncrementTxFilter

disableTable(HBaseAdmin, TableId) - Method in class co.cask.cdap.data2.util.hbase.HBase98TableUtil

E

enableTable(HBaseAdmin, TableId) - Method in class co.cask.cdap.data2.util.hbase.HBase98TableUtil

F

filterAllRemaining() - Method in class co.cask.cdap.data2.transaction.queue.coprocessor.hbase98.DequeueFilter

filterKeyValue(Cell) - Method in class co.cask.cdap.data2.increment.hbase98.IncrementFilter

filterRow() - Method in class co.cask.cdap.data2.transaction.queue.coprocessor.hbase98.DequeueFilter

filterRowCells(List<Cell>) - Method in class co.cask.cdap.data2.transaction.queue.coprocessor.hbase98.DequeueFilter

filterRowKey(byte[], int, int) - Method in class co.cask.cdap.data2.transaction.queue.coprocessor.hbase98.DequeueFilter

Filters - Class in co.cask.cdap.data2.increment.hbase98

Utility methods for working with HBase filters.

Filters() - Constructor for class co.cask.cdap.data2.increment.hbase98.Filters

from(HTableDescriptor) - Method in class co.cask.cdap.data2.util.hbase.HTable98NameConverter

G

getBloomFilter(HColumnDescriptor) - Method in class co.cask.cdap.data2.util.hbase.HBase98TableUtil

getCatalogTracker() - Method in class co.cask.cdap.data2.util.hbase.MockRegionServerServices

getCompactionRequester() - Method in class co.cask.cdap.data2.util.hbase.MockRegionServerServices

getCompression(HColumnDescriptor) - Method in class co.cask.cdap.data2.util.hbase.HBase98TableUtil

getConfiguration() - Method in class co.cask.cdap.data2.util.hbase.MockRegionServerServices

getDequeueScanObserverClassForVersion() - Method in class co.cask.cdap.data2.util.hbase.HBase98TableUtil

getExecutorService() - Method in class co.cask.cdap.data2.util.hbase.MockRegionServerServices

getFavoredNodesForRegion(String) - Method in class co.cask.cdap.data2.util.hbase.MockRegionServerServices

getFileSystem() - Method in class co.cask.cdap.data2.util.hbase.MockRegionServerServices

getFlushRequester() - Method in class co.cask.cdap.data2.util.hbase.MockRegionServerServices

getFromOnlineRegions(String) - Method in class co.cask.cdap.data2.util.hbase.MockRegionServerServices

getHTableDescriptor(HBaseAdmin, TableId) - Method in class co.cask.cdap.data2.util.hbase.HBase98TableUtil

getHTableNameConverter() - Method in class co.cask.cdap.data2.util.hbase.HBase98TableUtil

getIncrementHandlerClassForVersion() - Method in class co.cask.cdap.data2.util.hbase.HBase98TableUtil

getLeases() - Method in class co.cask.cdap.data2.util.hbase.MockRegionServerServices

getNonceManager() - Method in class co.cask.cdap.data2.util.hbase.MockRegionServerServices

getOnlineRegions(TableName) - Method in class co.cask.cdap.data2.util.hbase.MockRegionServerServices

getPriority(RPCProtos.RequestHeader, Message) - Method in class co.cask.cdap.data2.util.hbase.MockRegionServerServices

getQueueConsumer(CConfiguration, HTable, QueueName, HBaseConsumerState, HBaseConsumerStateStore, HBaseQueueStrategy) - Method in class co.cask.cdap.data2.transaction.queue.hbase.HBase98QueueUtil

getQueueRegionObserverClassForVersion() - Method in class co.cask.cdap.data2.util.hbase.HBase98TableUtil

getRecoveringRegions() - Method in class co.cask.cdap.data2.util.hbase.MockRegionServerServices

getRegionServerAccounting() - Method in class co.cask.cdap.data2.util.hbase.MockRegionServerServices

getRegionsInTransitionInRS() - Method in class co.cask.cdap.data2.util.hbase.MockRegionServerServices

getRpcServer() - Method in class co.cask.cdap.data2.util.hbase.MockRegionServerServices

getServerName() - Method in class co.cask.cdap.data2.util.hbase.MockRegionServerServices

getTableLockManager() - Method in class co.cask.cdap.data2.util.hbase.MockRegionServerServices

getTableRegions(HBaseAdmin, TableId) - Method in class co.cask.cdap.data2.util.hbase.HBase98TableUtil

getTransactionDataJanitorClassForVersion() - Method in class co.cask.cdap.data2.util.hbase.HBase98TableUtil

getTransactionFilter(Transaction, ScanType, Filter) - Method in class co.cask.cdap.data2.transaction.coprocessor.hbase98.DefaultTransactionProcessor

getTransactionStateCacheSupplier(RegionCoprocessorEnvironment) - Method in class co.cask.cdap.data2.transaction.coprocessor.hbase98.DefaultTransactionProcessor

getWAL(HRegionInfo) - Method in class co.cask.cdap.data2.util.hbase.MockRegionServerServices

getZooKeeper() - Method in class co.cask.cdap.data2.util.hbase.MockRegionServerServices

H

hasFilterRow() - Method in class co.cask.cdap.data2.transaction.queue.coprocessor.hbase98.DequeueFilter

hasNamespace(HBaseAdmin, String) - Method in class co.cask.cdap.data2.util.hbase.HBase98TableUtil

HBase98QueueUtil - Class in co.cask.cdap.data2.transaction.queue.hbase

HBase 0.98 implementation of HBaseQueueUtil.

HBase98QueueUtil() - Constructor for class co.cask.cdap.data2.transaction.queue.hbase.HBase98QueueUtil

HBase98TableUtil - Class in co.cask.cdap.data2.util.hbase

HBase98TableUtil() - Constructor for class co.cask.cdap.data2.util.hbase.HBase98TableUtil

HBaseQueueRegionObserver - Class in co.cask.cdap.data2.transaction.queue.coprocessor.hbase98

RegionObserver for queue table.

HBaseQueueRegionObserver() - Constructor for class co.cask.cdap.data2.transaction.queue.coprocessor.hbase98.HBaseQueueRegionObserver

HTable98NameConverter - Class in co.cask.cdap.data2.util.hbase

Utility methods for dealing with HBase table name conversions in HBase 0.98.

HTable98NameConverter() - Constructor for class co.cask.cdap.data2.util.hbase.HTable98NameConverter

I

IncrementFilter - Class in co.cask.cdap.data2.increment.hbase98

Simple filter for increment columns that includes all cell values in a column with a "delta" prefix up to and including the first cell it finds that is not an increment.

IncrementFilter() - Constructor for class co.cask.cdap.data2.increment.hbase98.IncrementFilter

IncrementHandler - Class in co.cask.cdap.data2.increment.hbase98

HBase coprocessor that handles reading and writing read-less increment operations.

IncrementHandler() - Constructor for class co.cask.cdap.data2.increment.hbase98.IncrementHandler

IncrementTxFilter - Class in co.cask.cdap.data2.increment.hbase98

TransactionVisibilityFilter's default behavior is to give only latest valid version for the transactional cell to its sub-filters.

IncrementTxFilter(Transaction, Map<byte[], Long>, boolean, ScanType, Filter) - Constructor for class co.cask.cdap.data2.increment.hbase98.IncrementTxFilter

Creates a new instance of the Filter.

isAborted() - Method in class co.cask.cdap.data2.util.hbase.MockRegionServerServices

isIncrement(Cell) - Static method in class co.cask.cdap.data2.increment.hbase98.IncrementHandler

isStopped() - Method in class co.cask.cdap.data2.util.hbase.MockRegionServerServices

isStopping() - Method in class co.cask.cdap.data2.util.hbase.MockRegionServerServices

L

listTables(HBaseAdmin) - Method in class co.cask.cdap.data2.util.hbase.HBase98TableUtil

listTablesInNamespace(HBaseAdmin, String) - Method in class co.cask.cdap.data2.util.hbase.HBase98TableUtil

M

MockRegionServerServices - Class in co.cask.cdap.data2.util.hbase

MockRegionServerServices(Configuration, ZooKeeperWatcher) - Constructor for class co.cask.cdap.data2.util.hbase.MockRegionServerServices

modifyTable(HBaseAdmin, HTableDescriptor) - Method in class co.cask.cdap.data2.util.hbase.HBase98TableUtil

P

parseFrom(byte[]) - Static method in class co.cask.cdap.data2.transaction.queue.coprocessor.hbase98.DequeueFilter

postOpenDeployTasks(HRegion, CatalogTracker) - Method in class co.cask.cdap.data2.util.hbase.MockRegionServerServices

postScannerOpen(ObserverContext<RegionCoprocessorEnvironment>, Scan, RegionScanner) - Method in class co.cask.cdap.data2.increment.hbase98.IncrementHandler

preCompact(ObserverContext<RegionCoprocessorEnvironment>, Store, InternalScanner, ScanType) - Method in class co.cask.cdap.data2.increment.hbase98.IncrementHandler

preCompact(ObserverContext<RegionCoprocessorEnvironment>, Store, InternalScanner, ScanType, CompactionRequest) - Method in class co.cask.cdap.data2.increment.hbase98.IncrementHandler

preCompact(ObserverContext<RegionCoprocessorEnvironment>, Store, InternalScanner, ScanType, CompactionRequest) - Method in class co.cask.cdap.data2.transaction.queue.coprocessor.hbase98.HBaseQueueRegionObserver

preDelete(ObserverContext<RegionCoprocessorEnvironment>, Delete, WALEdit, Durability) - Method in class co.cask.cdap.data2.increment.hbase98.IncrementHandler

preFlush(ObserverContext<RegionCoprocessorEnvironment>, Store, InternalScanner) - Method in class co.cask.cdap.data2.increment.hbase98.IncrementHandler

preFlush(ObserverContext<RegionCoprocessorEnvironment>, Store, InternalScanner) - Method in class co.cask.cdap.data2.transaction.queue.coprocessor.hbase98.HBaseQueueRegionObserver

preGetOp(ObserverContext<RegionCoprocessorEnvironment>, Get, List<Cell>) - Method in class co.cask.cdap.data2.increment.hbase98.IncrementHandler

prePut(ObserverContext<RegionCoprocessorEnvironment>, Put, WALEdit, Durability) - Method in class co.cask.cdap.data2.increment.hbase98.IncrementHandler

preScannerOpen(ObserverContext<RegionCoprocessorEnvironment>, Scan, RegionScanner) - Method in class co.cask.cdap.data2.increment.hbase98.IncrementHandler

preScannerOpen(ObserverContext<RegionCoprocessorEnvironment>, Scan, RegionScanner) - Method in class co.cask.cdap.data2.transaction.queue.coprocessor.hbase98.DequeueScanObserver

R

readFields(DataInput) - Method in class co.cask.cdap.data2.transaction.queue.coprocessor.hbase98.DequeueFilter

removeFromOnlineRegions(HRegion, ServerName) - Method in class co.cask.cdap.data2.util.hbase.MockRegionServerServices

reportRegionTransition(RegionServerStatusProtos.RegionTransition.TransitionCode, long, HRegionInfo...) - Method in class co.cask.cdap.data2.util.hbase.MockRegionServerServices

reportRegionTransition(RegionServerStatusProtos.RegionTransition.TransitionCode, HRegionInfo...) - Method in class co.cask.cdap.data2.util.hbase.MockRegionServerServices

reset() - Method in class co.cask.cdap.data2.transaction.queue.coprocessor.hbase98.DequeueFilter

S

setBloomFilter(HColumnDescriptor, HBaseTableUtil.BloomType) - Method in class co.cask.cdap.data2.util.hbase.HBase98TableUtil

setCompression(HColumnDescriptor, HBaseTableUtil.CompressionType) - Method in class co.cask.cdap.data2.util.hbase.HBase98TableUtil

setTimestampOracle(TimestampOracle) - Method in class co.cask.cdap.data2.increment.hbase98.IncrementHandler

start(CoprocessorEnvironment) - Method in class co.cask.cdap.data2.increment.hbase98.IncrementHandler

start(CoprocessorEnvironment) - Method in class co.cask.cdap.data2.transaction.queue.coprocessor.hbase98.HBaseQueueRegionObserver

stop(String) - Method in class co.cask.cdap.data2.util.hbase.MockRegionServerServices

T

tableExists(HBaseAdmin, TableId) - Method in class co.cask.cdap.data2.util.hbase.HBase98TableUtil

toByteArray() - Method in class co.cask.cdap.data2.transaction.queue.coprocessor.hbase98.DequeueFilter

toTableName(String, TableId) - Method in class co.cask.cdap.data2.util.hbase.HTable98NameConverter

U

updateRegionFavoredNodesMapping(String, List<HBaseProtos.ServerName>) - Method in class co.cask.cdap.data2.util.hbase.MockRegionServerServices

W

write(DataOutput) - Method in class co.cask.cdap.data2.transaction.queue.coprocessor.hbase98.DequeueFilter

A B C D E F G H I L M P R S T U W