com.bigdata.rdf.sparql.ast.ssets

Class SolutionSetManager

java.lang.Object

com.bigdata.rdf.sparql.ast.ssets.SolutionSetManager

All Implemented Interfaces:

ISolutionSetManager

public class SolutionSetManager
extends Object
implements ISolutionSetManager

A manager for named SOLUTION SETS scoped by some namespace and timestamp.

Author:

Bryan Thompson

See Also:

SPARQL Update , SPARQL UPDATE for NAMED SOLUTION SETS , Adaptive SPARQL Query Cache , SPARQL Query Cache

Constructor Summary

Constructors

Constructor and Description
SolutionSetManager(IBTreeManager store, String namespace, long timestamp)

Method Summary

Methods

Modifier and Type	Method and Description
void	clearAllSolutions() Clear all named solution sets.
boolean	clearSolutions(String solutionSet) Clear the specified named solution set.
void	close() Shutdown.
void	createSolutions(String solutionSet, ISPO[] params) Create a named solution set.
boolean	existsSolutions(String solutionSet) Return true iff a named solution set exists.
protected ISPO[]	getDefaultMetadata() Return the default metadata used when a named solution set is declared implicitly rather than explicitly.
ICloseableIterator<IBindingSet[]>	getSolutions(String solutionSet) Read the solutions from a named solution set.
ISolutionSetStats	getSolutionSetStats(String solutionSet) Return computed statistics for a named solution set.
void	init() One time initialization.
void	putSolutions(String solutionSet, ICloseableIterator<IBindingSet[]> src) Save the solutions into a named solution set.
String	toString()

Methods inherited from class java.lang.Object

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

Constructor Detail

SolutionSetManager

public SolutionSetManager(IBTreeManager store,
                  String namespace,
                  long timestamp)

Method Detail

toString

public String toString()

Overrides:

toString in class Object

init

public void init()

Description copied from interface: ISolutionSetManager

One time initialization.

Specified by:

init in interface ISolutionSetManager

close

public void close()

Shutdown.

Note: Explicit close is not safe. We want to destroy to cached solution sets if the AbstractTripleStore is destroyed. The hook is currently in AbstractResource.destroy().

Specified by:

close in interface ISolutionSetManager

clearAllSolutions

public void clearAllSolutions()

Description copied from interface: ISolutionSetManager

Clear all named solution sets.

Specified by:

clearAllSolutions in interface ISolutionSetManager

existsSolutions

public boolean existsSolutions(String solutionSet)

Description copied from interface: ISolutionSetManager

Return true iff a named solution set exists.

Specified by:

existsSolutions in interface ISolutionSetManager

Parameters:

solutionSet - The name of the solution set.

Returns:

true iff a solution set having that name exists.

clearSolutions

public boolean clearSolutions(String solutionSet)

Description copied from interface: ISolutionSetManager

Clear the specified named solution set.

Specified by:

clearSolutions in interface ISolutionSetManager

Parameters:

solutionSet - The name of the solution set.

Returns:

true iff a solution set by that name existed and was cleared.

putSolutions

public void putSolutions(String solutionSet,
                ICloseableIterator<IBindingSet[]> src)

Description copied from interface: ISolutionSetManager

Save the solutions into a named solution set. If there is an existing solution set having that name, then its solutions will be replaced by the new solutions (replace not append).

Specified by:

putSolutions in interface ISolutionSetManager

Parameters:

solutionSet - The name of the solution set.

src - The solutions.

createSolutions

public void createSolutions(String solutionSet,
                   ISPO[] params)

Description copied from interface: ISolutionSetManager

Create a named solution set.

Specified by:

createSolutions in interface ISolutionSetManager

Parameters:

solutionSet - The name of the solution set.

params - The configuration parameters (optional).

getSolutionSetStats

public ISolutionSetStats getSolutionSetStats(String solutionSet)

Description copied from interface: ISolutionSetManager

Return computed statistics for a named solution set.

Specified by:

getSolutionSetStats in interface ISolutionSetManager

Parameters:

solutionSet - The name of the solution set.

Returns:

The statistics -or- null if there is no such named solution set.

getSolutions

public ICloseableIterator<IBindingSet[]> getSolutions(String solutionSet)

Description copied from interface: ISolutionSetManager

Read the solutions from a named solution set.

Specified by:

getSolutions in interface ISolutionSetManager

Parameters:

solutionSet - The name of the solution set.

Returns:

An iterator from which the solutions may be drained.

getDefaultMetadata

protected ISPO[] getDefaultMetadata()

Return the default metadata used when a named solution set is declared implicitly rather than explicitly.

Returns:

The metadata describing that solution set. TODO This is ignored and needs to be reconciled with IndexMetadata. However, we do want to provide this metadata in a CREATE schema as triples.