org.datanucleus.store.hbase

Class HBaseManagedConnection

java.lang.Object

org.datanucleus.store.connection.AbstractManagedConnection

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

Constructors

Constructor and Description
HBaseManagedConnection(org.apache.hadoop.hbase.client.HTablePool pool)

Method Summary

Methods

Modifier and Type	Method and Description
void	close()
void	dispose()
Object	getConnection()
org.apache.hadoop.hbase.client.HTableInterface	getHTable(String tableName)
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, closeAfterTransactionEnd, closeOnRelease, commitOnRelease, isLocked, lock, removeListener, setCloseOnRelease, setCommitOnRelease, 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.hbase.client.HTablePool pool)

Method Detail

getConnection

public Object getConnection()

getHTable

public org.apache.hadoop.hbase.client.HTableInterface getHTable(String tableName)

getXAResource

public 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()