org.datanucleus.store.hbase
Class HBaseManagedConnection

java.lang.Object
  extended by org.datanucleus.store.connection.AbstractManagedConnection
      extended by org.datanucleus.store.hbase.HBaseManagedConnection
All Implemented Interfaces:
org.datanucleus.store.connection.ManagedConnection

public class HBaseManagedConnection
extends org.datanucleus.store.connection.AbstractManagedConnection

Implementation of a ManagedConnection.


Field Summary
 
Fields inherited from class org.datanucleus.store.connection.AbstractManagedConnection
closeOnRelease, commitOnRelease, conn, listeners, locked, useCount
 
Constructor Summary
HBaseManagedConnection(org.apache.hadoop.conf.Configuration config)
           
 
Method Summary
 void close()
           
 void dispose()
           
 java.lang.Object getConnection()
           
 org.apache.hadoop.hbase.client.HTable getHTable(java.lang.String tableName)
           
 javax.transaction.xa.XAResource getXAResource()
           
protected  void incrementUseCount()
           
 boolean isDisposed()
           
 boolean isExpired()
           
 void release()
           
 void setIdleTimeoutMills(int mills)
           
 
Methods inherited from class org.datanucleus.store.connection.AbstractManagedConnection
addListener, isLocked, lock, removeListener, setManagedResource, setPooled, toString, transactionFlushed, transactionPreClose, unlock
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
 

Constructor Detail

HBaseManagedConnection

public HBaseManagedConnection(org.apache.hadoop.conf.Configuration config)
Method Detail

getConnection

public java.lang.Object getConnection()

getHTable

public org.apache.hadoop.hbase.client.HTable getHTable(java.lang.String tableName)

getXAResource

public javax.transaction.xa.XAResource getXAResource()
Specified by:
getXAResource in interface org.datanucleus.store.connection.ManagedConnection
Overrides:
getXAResource in class org.datanucleus.store.connection.AbstractManagedConnection

close

public void close()

incrementUseCount

protected void incrementUseCount()
Overrides:
incrementUseCount in class org.datanucleus.store.connection.AbstractManagedConnection

release

public void release()
Specified by:
release in interface org.datanucleus.store.connection.ManagedConnection
Overrides:
release in class org.datanucleus.store.connection.AbstractManagedConnection

setIdleTimeoutMills

public void setIdleTimeoutMills(int mills)

isExpired

public boolean isExpired()

dispose

public void dispose()

isDisposed

public boolean isDisposed()


Copyright © 2012. All Rights Reserved.