com.bigdata.rdf.sparql.ast.cache

Class CacheConnectionImpl

java.lang.Object

com.bigdata.rdf.sparql.ast.cache.CacheConnectionImpl

All Implemented Interfaces:

ICacheConnection

public class CacheConnectionImpl
extends Object
implements ICacheConnection

A connection to a local, remote, or distributed caching layer.

Version:

$Id$

Author:

Bryan Thompson

Constructor Summary

Constructors

Constructor and Description
CacheConnectionImpl(QueryEngine queryEngine) Note: A distributed cache fabric could be accessed from any node in a cluster.

Method Summary

Methods

Modifier and Type	Method and Description
void	close() Close the cache / cache connection.
void	destroyCaches(String namespace, long timestamp) Destroy the cache(s) associated with that namespace.
protected void	finalize() CacheConnectionImpl is used with a singleton pattern managed by the CacheConnectionFactory.
IDescribeCache	getDescribeCache(String namespace, long timestamp) Return a view of a maintained DESCRIBE cache.
void	init() Initialize the cache / cache connection.

Methods inherited from class java.lang.Object

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

Constructor Detail

CacheConnectionImpl

public CacheConnectionImpl(QueryEngine queryEngine)

Note: A distributed cache fabric could be accessed from any node in a cluster. That means that this could be the Journal -or- the IndexManager inside the IDataService and provides direct access to FusedViews (aka shards).

Parameters:

queryEngine - The QueryEngine.

Method Detail

init

public void init()

Description copied from interface: ICacheConnection

Initialize the cache / cache connection.

Specified by:

init in interface ICacheConnection

close

public void close()

Description copied from interface: ICacheConnection

Close the cache / cache connection.

Specified by:

close in interface ICacheConnection

destroyCaches

public void destroyCaches(String namespace,
                 long timestamp)

Description copied from interface: ICacheConnection

Destroy the cache(s) associated with that namespace.

Specified by:

destroyCaches in interface ICacheConnection

Parameters:

namespace - The KB namespace.

finalize

protected void finalize()
                 throws Throwable

CacheConnectionImpl is used with a singleton pattern managed by the CacheConnectionFactory. It will be torn down automatically it is no longer reachable. This behavior depends on not having any hard references back to the QueryEngine.

Overrides:

finalize in class Object

Throws:

Throwable

getDescribeCache

public IDescribeCache getDescribeCache(String namespace,
                              long timestamp)

Description copied from interface: ICacheConnection

Return a view of a maintained DESCRIBE cache.

Specified by:

getDescribeCache in interface ICacheConnection

Parameters:

namespace - The KB namespace.

timestamp - The timestamp of the view.

Returns:

The DESCRIBE cache for that view -or- null if the DESCRIBE cache is not enabled.

See Also:

QueryHints.DESCRIBE_CACHE