org.apache.marmotta.kiwi.persistence.registry

Class CacheTripleRegistry

java.lang.Object

org.apache.marmotta.kiwi.persistence.registry.CacheTripleRegistry

All Implemented Interfaces:

KiWiTripleRegistry

public class CacheTripleRegistry
extends Object
implements KiWiTripleRegistry

A triple registry implementation based on the Infinispan cache. Registry entries are stored in a replicated, synchronized Infinispan cache. Transaction information is kept locally.

Author:

Sebastian Schaffert (sschaffert@apache.org)

Constructor Summary

Constructors

Constructor and Description
CacheTripleRegistry(CacheManager cacheManager)

Method Summary

Methods

Modifier and Type	Method and Description
void	deleteKey(IntArray key) Remove the key with the given key, e.g.
long	lookupKey(IntArray key) Check if another (or the same) transaction has already registered an ID for the triple with the given key.
void	registerKey(IntArray key, long transactionId, long tripleId) Register a key/triple id pair in the triple registry for the given transaction ID.
void	releaseTransaction(long transactionId) Free all registry entries claimed by the transaction with the given identifier.

Methods inherited from class java.lang.Object

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

Constructor Detail

CacheTripleRegistry

public CacheTripleRegistry(CacheManager cacheManager)

Method Detail

registerKey

public void registerKey(IntArray key,
               long transactionId,
               long tripleId)

Register a key/triple id pair in the triple registry for the given transaction ID.

Specified by:

registerKey in interface KiWiTripleRegistry

Parameters:

key - the key identifying the triple arguments (subject, object, predicate, context)

transactionId - the identifier of the transaction registering the triple id

tripleId - the new triple identifier

lookupKey

public long lookupKey(IntArray key)

Check if another (or the same) transaction has already registered an ID for the triple with the given key. Returns -1 in case no other ID has been registered, or a value >0 otherwise.

Specified by:

lookupKey in interface KiWiTripleRegistry

Parameters:

key - the key identifying the triple arguments (subject, object, predicate, context)

Returns:

id of the triple or -1

releaseTransaction

public void releaseTransaction(long transactionId)

Free all registry entries claimed by the transaction with the given identifier. Should remove or expire all registry entries to avoid unnecessary storage consumption.

Specified by:

releaseTransaction in interface KiWiTripleRegistry

Parameters:

transactionId - the identifier of the transaction registering the triple id

deleteKey

public void deleteKey(IntArray key)

Remove the key with the given key, e.g. when a statement is again deleted during a transaction.

Specified by:

deleteKey in interface KiWiTripleRegistry

Parameters:

key - the key identifying the triple arguments (subject, object, predicate, context)