org.fcrepo.indexer.sparql

Class SparqlIndexer

java.lang.Object

org.fcrepo.indexer.AsynchIndexer<com.hp.hpl.jena.rdf.model.Model,Void>

org.fcrepo.indexer.sparql.SparqlIndexer

All Implemented Interfaces:

Indexer<com.hp.hpl.jena.rdf.model.Model>

public class SparqlIndexer
extends AsynchIndexer<com.hp.hpl.jena.rdf.model.Model,Void>

Indexes triples from Fedora into a triplestore using SPARQL Update.

Author:

Esmé Cowles, ajs6f

Nested Class Summary

Nested classes/interfaces inherited from interface org.fcrepo.indexer.Indexer

Indexer.IndexerType, Indexer.NoContent

Constructor Summary

Constructors

Constructor and Description
SparqlIndexer()

Method Summary

Methods

Modifier and Type	Method and Description
protected com.hp.hpl.jena.sparql.engine.http.QueryEngineHTTP	buildQueryEngineHTTP(String describeQuery) Note: Protected for Unit Tests to overwrite.
protected com.hp.hpl.jena.update.UpdateRequest	buildUpdateRequest() Note: Protected for Unit Tests to overwrite.
com.google.common.util.concurrent.ListeningExecutorService	executorService()
Indexer.IndexerType	getIndexerType()
Callable<Void>	removeSynch(String subject) Perform a DESCRIBE query for triples about the Fedora object and remove all triples with subjects starting with the same subject.
void	setFormUpdates(boolean b) Set whether to use SPARQL Update or form updates.
void	setQueryBase(String url) Set base URL for SPARQL Query requests.
void	setUpdateBase(String url) Set base URL for SPARQL Update requests.
Callable<Void>	updateSynch(String pid, com.hp.hpl.jena.rdf.model.Model model) Remove any current triples about the Fedora object and replace them with the provided content.

Methods inherited from class org.fcrepo.indexer.AsynchIndexer

remove, update

Methods inherited from class java.lang.Object

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

Constructor Detail

SparqlIndexer

public SparqlIndexer()

Method Detail

updateSynch

public Callable<Void> updateSynch(String pid,
                         com.hp.hpl.jena.rdf.model.Model model)

Remove any current triples about the Fedora object and replace them with the provided content.

Specified by:

updateSynch in class AsynchIndexer<com.hp.hpl.jena.rdf.model.Model,Void>

Returns:

removeSynch

public Callable<Void> removeSynch(String subject)

Perform a DESCRIBE query for triples about the Fedora object and remove all triples with subjects starting with the same subject.

Specified by:

removeSynch in class AsynchIndexer<com.hp.hpl.jena.rdf.model.Model,Void>

Returns:

getIndexerType

public Indexer.IndexerType getIndexerType()

Returns:

What kind of indexer this is.

setFormUpdates

public void setFormUpdates(boolean b)

Set whether to use SPARQL Update or form updates.

setQueryBase

public void setQueryBase(String url)

Set base URL for SPARQL Query requests.

setUpdateBase

public void setUpdateBase(String url)

Set base URL for SPARQL Update requests.

executorService

public com.google.common.util.concurrent.ListeningExecutorService executorService()

Specified by:

executorService in class AsynchIndexer<com.hp.hpl.jena.rdf.model.Model,Void>

Returns:

The ListeningExecutorService to use for operation.

buildQueryEngineHTTP

protected com.hp.hpl.jena.sparql.engine.http.QueryEngineHTTP buildQueryEngineHTTP(String describeQuery)

Note: Protected for Unit Tests to overwrite.

buildUpdateRequest

protected com.hp.hpl.jena.update.UpdateRequest buildUpdateRequest()

Note: Protected for Unit Tests to overwrite.