com.bigdata.rdf.sail.remote

Class BigdataSailRemoteRepository

java.lang.Object

com.bigdata.rdf.sail.remote.BigdataSailRemoteRepository

All Implemented Interfaces:

org.openrdf.repository.Repository

public class BigdataSailRemoteRepository
extends Object
implements org.openrdf.repository.Repository

An fully compliant implementation of Sesame's Repository that wraps the blazegraph remote API. Additional functionality is available using the blazegraph RemoteRepositoryManager. The proper incantation to create an instance of this class is:

 // Create client for the remote service.
 final RemoteRepositoryManager mgr = new RemoteRepositoryManager(serviceURL);
 try {
    // Obtain a Sesame Repository for the default sparql endpoint on that
    // service.
    final Repository repo = mgr.getRepositoryForDefaultNamespace()
          .getBigdataSailRemoteRepository();
    try {
       doWork(repo);
    } finally {
       repo.close();
    }
 } finally {
    mgr.close();
 }
 

This pattern makes it possible to:

• Obtain BigdataSailRemoteRepository objects for different sparql end points on the same blazegraph server.
• Those BigdataSailRemoteRepository objects are flyweight.
• The RemoteRepositoryManager can be used to access additional interfaces, including the multi-tenancy API and the transaction API.

Transactions

The database supports read/write transactions since 1.5.2. Transaction manager is at the database layer, not the Repository or RepositoryConnection. Therefore a namespace DOES NOT need to be configured for isolatable indices in order to create and manipulate transactions, but it DOES need to be configured with isolatable indices in order for you to WRITE on the namespace using a transaction.

See Also:

RemoteTransactionManager, BigdataSail.Options.ISOLATABLE_INDICES, BigdataSailRemoteRepositoryConnection

Constructor Summary

Constructors

Constructor and Description
BigdataSailRemoteRepository(RemoteRepository repo) Flyweight constructor wraps the blazegraph remote client for a SPARQL endpoint as an openrdf Repository.
BigdataSailRemoteRepository(String sparqlEndpointURL) Deprecated.

Method Summary

Methods

Modifier and Type	Method and Description
void	cancel(UUID queryId) Cancel the query specified by the UUID.
BigdataSailRemoteRepositoryConnection	getConnection()
File	getDataDir() Unsupported operation
RemoteRepository	getRemoteRepository() The object used to communicate with that remote repository.
org.openrdf.model.ValueFactory	getValueFactory() Return a client-only ValueFactory implementation.
void	initialize()
boolean	isInitialized()
boolean	isWritable()
void	setDataDir(File dataDir) Unsupported operation
Collection<RunningQuery>	showQueries() Return a collection containing Metadata objects about the currently running queries.
void	shutDown()

Methods inherited from class java.lang.Object

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

Constructor Detail

BigdataSailRemoteRepository

@Deprecated
public BigdataSailRemoteRepository(String sparqlEndpointURL)

Deprecated.

Constructor that simply specifies an endpoint. This class will internally allocate a RemoteRepositoryManager that is scoped to the life cycle of this class. The allocated RemoteRepositoryManager will be closed when this BigdataSailRemoteRepository is closed.

Note: This constructor pattern is NOT flyweight.

Parameters:

sparqlEndpointURL - The SPARQL end point URL

BigdataSailRemoteRepository

public BigdataSailRemoteRepository(RemoteRepository repo)

Flyweight constructor wraps the blazegraph remote client for a SPARQL endpoint as an openrdf Repository.

See Also:

RemoteRepository.getBigdataSailRemoteRepository()

Method Detail

getRemoteRepository

public RemoteRepository getRemoteRepository()

The object used to communicate with that remote repository.

shutDown

public void shutDown()
              throws org.openrdf.repository.RepositoryException

Specified by:

shutDown in interface org.openrdf.repository.Repository

Throws:

org.openrdf.repository.RepositoryException

getConnection

public BigdataSailRemoteRepositoryConnection getConnection()
                                                    throws org.openrdf.repository.RepositoryException

Specified by:

getConnection in interface org.openrdf.repository.Repository

Throws:

org.openrdf.repository.RepositoryException

initialize

public void initialize()
                throws org.openrdf.repository.RepositoryException

Specified by:

initialize in interface org.openrdf.repository.Repository

Throws:

org.openrdf.repository.RepositoryException

isInitialized

public boolean isInitialized()

Specified by:

isInitialized in interface org.openrdf.repository.Repository

isWritable

public boolean isWritable()
                   throws org.openrdf.repository.RepositoryException

Specified by:

isWritable in interface org.openrdf.repository.Repository

Throws:

org.openrdf.repository.RepositoryException

setDataDir

public void setDataDir(File dataDir)

Unsupported operation

Specified by:

setDataDir in interface org.openrdf.repository.Repository

Throws:

UnsupportedOperationException

getDataDir

public File getDataDir()

Unsupported operation

Specified by:

getDataDir in interface org.openrdf.repository.Repository

Throws:

UnsupportedOperationException

getValueFactory

public org.openrdf.model.ValueFactory getValueFactory()

Return a client-only ValueFactory implementation.

Specified by:

getValueFactory in interface org.openrdf.repository.Repository

cancel

public void cancel(UUID queryId)
            throws Exception

Cancel the query specified by the UUID.

Parameters:

queryId -

Throws:

Exception

showQueries

public Collection<RunningQuery> showQueries()
                                     throws Exception

Return a collection containing Metadata objects about the currently running queries.

Returns:

Throws:

Exception