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

Class DefaultTransactionProcessor

java.lang.Object

org.apache.hadoop.hbase.coprocessor.BaseRegionObserver

org.apache.tephra.hbase.coprocessor.TransactionProcessor

co.cask.cdap.data2.transaction.coprocessor.hbase98.DefaultTransactionProcessor

All Implemented Interfaces:

org.apache.hadoop.hbase.Coprocessor, org.apache.hadoop.hbase.coprocessor.RegionObserver

public class DefaultTransactionProcessor
extends org.apache.tephra.hbase.coprocessor.TransactionProcessor

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

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.hadoop.hbase.coprocessor.RegionObserver

org.apache.hadoop.hbase.coprocessor.RegionObserver.MutationType

Nested classes/interfaces inherited from interface org.apache.hadoop.hbase.Coprocessor

org.apache.hadoop.hbase.Coprocessor.State

Field Summary

Fields inherited from class org.apache.tephra.hbase.coprocessor.TransactionProcessor

allowEmptyValues, readNonTxnData, ttlByFamily

Fields inherited from interface org.apache.hadoop.hbase.Coprocessor

PRIORITY_HIGHEST, PRIORITY_LOWEST, PRIORITY_SYSTEM, PRIORITY_USER, VERSION

Constructor Summary

Constructors

Constructor and Description
DefaultTransactionProcessor()

Method Summary

Methods

Modifier and Type	Method and Description
protected org.apache.hadoop.hbase.filter.Filter	getTransactionFilter(org.apache.tephra.Transaction tx, org.apache.hadoop.hbase.regionserver.ScanType scanType, org.apache.hadoop.hbase.filter.Filter filter)
protected com.google.common.base.Supplier<org.apache.tephra.coprocessor.TransactionStateCache>	getTransactionStateCacheSupplier(org.apache.hadoop.hbase.coprocessor.RegionCoprocessorEnvironment env)

Methods inherited from class org.apache.tephra.hbase.coprocessor.TransactionProcessor

createStoreScanner, preCompactScannerOpen, preDelete, preFlushScannerOpen, preGetOp, preScannerOpen, start, stop

Methods inherited from class org.apache.hadoop.hbase.coprocessor.BaseRegionObserver

postAppend, postBatchMutate, postBatchMutateIndispensably, postBulkLoadHFile, postCheckAndDelete, postCheckAndPut, postClose, postCloseRegionOperation, postCompact, postCompact, postCompactSelection, postCompactSelection, postCompleteSplit, postDelete, postExists, postFlush, postFlush, postGet, postGetClosestRowBefore, postGetOp, postIncrement, postIncrementColumnValue, postInstantiateDeleteTracker, postLogReplay, postMutationBeforeWAL, postOpen, postPut, postRollBackSplit, postScannerClose, postScannerFilterRow, postScannerNext, postScannerOpen, postSplit, postStartRegionOperation, postStoreFileReaderOpen, postWALRestore, preAppend, preAppendAfterRowLock, preBatchMutate, preBulkLoadHFile, preCheckAndDelete, preCheckAndDeleteAfterRowLock, preCheckAndPut, preCheckAndPutAfterRowLock, preClose, preCompact, preCompact, preCompactScannerOpen, preCompactSelection, preCompactSelection, preExists, preFlush, preFlush, preGet, preGetClosestRowBefore, preIncrement, preIncrementAfterRowLock, preIncrementColumnValue, preOpen, prePrepareTimeStampForDeleteVersion, prePut, preRollBackSplit, preScannerClose, preScannerNext, preSplit, preSplit, preSplitAfterPONR, preSplitBeforePONR, preStoreFileReaderOpen, preStoreScannerOpen, preWALRestore

Methods inherited from class java.lang.Object

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

Constructor Detail

DefaultTransactionProcessor

public DefaultTransactionProcessor()

Method Detail

getTransactionStateCacheSupplier

protected com.google.common.base.Supplier<org.apache.tephra.coprocessor.TransactionStateCache> getTransactionStateCacheSupplier(org.apache.hadoop.hbase.coprocessor.RegionCoprocessorEnvironment env)

Overrides:

getTransactionStateCacheSupplier in class org.apache.tephra.hbase.coprocessor.TransactionProcessor

getTransactionFilter

protected org.apache.hadoop.hbase.filter.Filter getTransactionFilter(org.apache.tephra.Transaction tx,
                                                         org.apache.hadoop.hbase.regionserver.ScanType scanType,
                                                         org.apache.hadoop.hbase.filter.Filter filter)

Overrides:

getTransactionFilter in class org.apache.tephra.hbase.coprocessor.TransactionProcessor