Package org.aksw.commons.store.object.key.impl

Class ObjectStoreImpl

java.lang.Object

org.aksw.commons.store.object.key.impl.ObjectStoreImpl

All Implemented Interfaces:

AutoCloseable, ObjectStore

public class ObjectStoreImpl
extends Object
implements ObjectStore

Field Summary

Fields

Modifier and Type	Field	Description
protected org.aksw.commons.cache.async.AsyncClaimingCache<org.aksw.commons.path.core.Path<String>,ObjectResource>	accessorCache
protected org.aksw.commons.cache.async.AsyncClaimingCache<org.aksw.commons.path.core.Path<String>,ObjectInfo>	contentCache
protected ObjectSerializer	objectSerializer
protected org.aksw.commons.txn.impl.TxnHandlerImpl	txnHandler
protected org.aksw.commons.txn.api.TxnMgr	txnMgr

Constructor Summary

Constructors

Constructor	Description
ObjectStoreImpl(org.aksw.commons.txn.api.TxnMgr txnMgr, org.aksw.commons.txn.impl.TxnHandlerImpl txnHandler, ObjectSerializer objectSerializer, org.aksw.commons.cache.async.AsyncClaimingCache<org.aksw.commons.path.core.Path<String>,ObjectInfo> contentCache, org.aksw.commons.cache.async.AsyncClaimingCache<org.aksw.commons.path.core.Path<String>,ObjectResource> accessorCache)

Method Summary

Modifier and Type	Method	Description
org.aksw.commons.util.ref.RefFuture<ObjectInfo>	claim(org.aksw.commons.path.core.Path<String> key)	Asynchronously attempt to claim to the given resource.
void	close()
static ObjectStore	create(Path rootPath, ObjectSerializer objectSerializer)
org.aksw.commons.txn.impl.PathDiffState	fetchRecencyStatus(org.aksw.commons.path.core.Path<String> key)
ObjectStoreConnection	getConnection()
protected static void	save(org.aksw.commons.txn.api.TxnMgr txnMgr, ObjectSerializer objectSerializer, org.aksw.commons.txn.impl.TxnHandlerImpl txnHandler, org.aksw.commons.path.core.Path<String> key, ObjectInfo v)

Methods inherited from class java.lang.Object

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

Field Details

txnMgr

protected org.aksw.commons.txn.api.TxnMgr txnMgr

txnHandler

protected org.aksw.commons.txn.impl.TxnHandlerImpl txnHandler

objectSerializer

protected ObjectSerializer objectSerializer

contentCache

protected org.aksw.commons.cache.async.AsyncClaimingCache<org.aksw.commons.path.core.Path<String>,ObjectInfo> contentCache

accessorCache

protected org.aksw.commons.cache.async.AsyncClaimingCache<org.aksw.commons.path.core.Path<String>,ObjectResource> accessorCache

Constructor Details

ObjectStoreImpl

public ObjectStoreImpl(org.aksw.commons.txn.api.TxnMgr txnMgr,
 org.aksw.commons.txn.impl.TxnHandlerImpl txnHandler,
 ObjectSerializer objectSerializer,
 org.aksw.commons.cache.async.AsyncClaimingCache<org.aksw.commons.path.core.Path<String>,ObjectInfo> contentCache,
 org.aksw.commons.cache.async.AsyncClaimingCache<org.aksw.commons.path.core.Path<String>,ObjectResource> accessorCache)

Method Details

fetchRecencyStatus

public org.aksw.commons.txn.impl.PathDiffState fetchRecencyStatus(org.aksw.commons.path.core.Path<String> key)

Specified by:

fetchRecencyStatus in interface ObjectStore

create

public static ObjectStore create(Path rootPath,
 ObjectSerializer objectSerializer)

save

protected static void save(org.aksw.commons.txn.api.TxnMgr txnMgr,
 ObjectSerializer objectSerializer,
 org.aksw.commons.txn.impl.TxnHandlerImpl txnHandler,
 org.aksw.commons.path.core.Path<String> key,
 ObjectInfo v)
                    throws IOException

Throws:

IOException

claim

public org.aksw.commons.util.ref.RefFuture<ObjectInfo> claim(org.aksw.commons.path.core.Path<String> key)

Description copied from interface: ObjectStore

Asynchronously attempt to claim to the given resource.

Specified by:

claim in interface ObjectStore

Parameters:

key -

Returns:

getConnection

public ObjectStoreConnection getConnection()

Specified by:

getConnection in interface ObjectStore

close

public void close()
           throws Exception

Specified by:

close in interface AutoCloseable

Throws:

Exception