org.aksw.sparqlify.update

Class IncrementalQueryUpdateManager

java.lang.Object

org.aksw.sparqlify.update.IncrementalQueryUpdateManager

public class IncrementalQueryUpdateManager
extends Object

Keeps track of changes to a sparql query result in the course of updates.

Author:

Claus Stadler

Constructor Summary

Constructors

Constructor and Description
IncrementalQueryUpdateManager(String queryString, ModelSparqlEndpoint sparqlEndpoint)

Method Summary

Methods

Modifier and Type	Method and Description
void	add(com.hp.hpl.jena.sparql.core.Quad quad) This method must only be called for triples that were actually added to the underlying store.
void	computeDeletions()
void	computeInserts()
boolean	doesExist(com.hp.hpl.jena.sparql.core.Quad quad) Checks whether the given quad already exists in the store.
org.aksw.commons.collections.diff.HashSetDiff<com.hp.hpl.jena.sparql.engine.binding.Binding>	getChanges()
boolean	isRelevant(com.hp.hpl.jena.sparql.core.Quad quad) Checks whether the given quad is relevant to this view.
void	onPostBatchEnd()
void	onPostBatchStart()
void	onPostDelete(com.hp.hpl.jena.sparql.core.Quad quad)
void	onPostInsert(com.hp.hpl.jena.sparql.core.Quad quad)
void	onPreBatchEnd()
void	onPreBatchStart()
void	onPreDelete(com.hp.hpl.jena.sparql.core.Quad quad)
void	onPreInsert(com.hp.hpl.jena.sparql.core.Quad quad)
com.hp.hpl.jena.query.ResultSet	processQuads(Iterable<com.hp.hpl.jena.sparql.core.Quad> quads)
void	remove(com.hp.hpl.jena.sparql.core.Quad quad)
void	removeSeen(com.hp.hpl.jena.sparql.core.Quad quad) This method must only be called for triples that were actually removed from the underlying store.
static Set<com.hp.hpl.jena.sparql.engine.binding.Binding>	resultSetToBindings(com.hp.hpl.jena.query.ResultSet rs)
static void	sparqlIntoView(ModelSparqlEndpoint sparqlEndpoint, String queryString, ViewTable viewTable)

Methods inherited from class java.lang.Object

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

Constructor Detail

IncrementalQueryUpdateManager

public IncrementalQueryUpdateManager(String queryString,
                             ModelSparqlEndpoint sparqlEndpoint)
                              throws SQLException

Throws:

SQLException

Method Detail

isRelevant

public boolean isRelevant(com.hp.hpl.jena.sparql.core.Quad quad)

Checks whether the given quad is relevant to this view.

Parameters:

quad -

Returns:

doesExist

public boolean doesExist(com.hp.hpl.jena.sparql.core.Quad quad)

Checks whether the given quad already exists in the store. FIXME Implement for batched checking

Parameters:

quad -

Returns:

processQuads

public com.hp.hpl.jena.query.ResultSet processQuads(Iterable<com.hp.hpl.jena.sparql.core.Quad> quads)

removeSeen

public void removeSeen(com.hp.hpl.jena.sparql.core.Quad quad)

This method must only be called for triples that were actually removed from the underlying store. Otherwise the view will go out of sync.

Parameters:

quad -

add

public void add(com.hp.hpl.jena.sparql.core.Quad quad)

This method must only be called for triples that were actually added to the underlying store. Otherwise the view will go out of sync.

Parameters:

quad -

resultSetToBindings

public static Set<com.hp.hpl.jena.sparql.engine.binding.Binding> resultSetToBindings(com.hp.hpl.jena.query.ResultSet rs)

getChanges

public org.aksw.commons.collections.diff.HashSetDiff<com.hp.hpl.jena.sparql.engine.binding.Binding> getChanges()

computeInserts

public void computeInserts()

computeDeletions

public void computeDeletions()

remove

public void remove(com.hp.hpl.jena.sparql.core.Quad quad)

sparqlIntoView

public static void sparqlIntoView(ModelSparqlEndpoint sparqlEndpoint,
                  String queryString,
                  ViewTable viewTable)
                           throws SQLException

Throws:

SQLException

onPreBatchStart

public void onPreBatchStart()

onPreInsert

public void onPreInsert(com.hp.hpl.jena.sparql.core.Quad quad)

onPreDelete

public void onPreDelete(com.hp.hpl.jena.sparql.core.Quad quad)

onPreBatchEnd

public void onPreBatchEnd()

onPostBatchStart

public void onPostBatchStart()

onPostInsert

public void onPostInsert(com.hp.hpl.jena.sparql.core.Quad quad)

onPostDelete

public void onPostDelete(com.hp.hpl.jena.sparql.core.Quad quad)

onPostBatchEnd

public void onPostBatchEnd()