com.splicemachine.access.hbase

Class H10TxnNetworkLayer

java.lang.Object

com.splicemachine.si.impl.SkeletonTxnNetworkLayer

com.splicemachine.access.hbase.H10TxnNetworkLayer

All Implemented Interfaces:

TxnNetworkLayer, java.lang.AutoCloseable

public class H10TxnNetworkLayer
extends SkeletonTxnNetworkLayer

Constructor Summary

Constructors

Constructor and Description
H10TxnNetworkLayer(org.apache.hadoop.hbase.client.Table table)

Method Summary

Modifier and Type	Method and Description
void	close()
protected <C> java.util.Map<byte[],C>	coprocessorService(java.lang.Class<com.splicemachine.si.coprocessor.TxnMessage.TxnLifecycleService> txnLifecycleServiceClass, byte[] startRow, byte[] endRow, org.apache.hadoop.hbase.client.coprocessor.Batch.Call<com.splicemachine.si.coprocessor.TxnMessage.TxnLifecycleService,C> call)
protected com.splicemachine.si.coprocessor.TxnMessage.TxnLifecycleService	getLifecycleService(byte[] rowKey)

Methods inherited from class com.splicemachine.si.impl.SkeletonTxnNetworkLayer

beginTransaction, elevate, getActiveTxnIds, getActiveTxns, getTaskId, getTxn, lifecycleAction

Methods inherited from class java.lang.Object

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

Constructor Detail

H10TxnNetworkLayer

public H10TxnNetworkLayer(org.apache.hadoop.hbase.client.Table table)

Method Detail

close

public void close()
           throws java.io.IOException

Throws:

java.io.IOException

getLifecycleService

protected com.splicemachine.si.coprocessor.TxnMessage.TxnLifecycleService getLifecycleService(byte[] rowKey)
                                                                                       throws java.io.IOException

Specified by:

getLifecycleService in class SkeletonTxnNetworkLayer

Throws:

java.io.IOException

coprocessorService

protected <C> java.util.Map<byte[],C> coprocessorService(java.lang.Class<com.splicemachine.si.coprocessor.TxnMessage.TxnLifecycleService> txnLifecycleServiceClass,
                                                         byte[] startRow,
                                                         byte[] endRow,
                                                         org.apache.hadoop.hbase.client.coprocessor.Batch.Call<com.splicemachine.si.coprocessor.TxnMessage.TxnLifecycleService,C> call)
                                                  throws java.io.IOException

Specified by:

coprocessorService in class SkeletonTxnNetworkLayer

Throws:

java.io.IOException