Package org.eclipse.rdf4j.sail.solr
Class SolrIndex
java.lang.Object
org.eclipse.rdf4j.sail.lucene.AbstractSearchIndex
org.eclipse.rdf4j.sail.solr.SolrIndex
-
Field Summary
Fields inherited from class org.eclipse.rdf4j.sail.lucene.AbstractSearchIndex
maxDocs, wktFields
-
Constructor Summary
-
Method Summary
Modifier and TypeMethodDescriptionprotected void
void
begin()
Begins a transaction.void
clear()
Clears the indexes.void
clearContexts
(Resource... contexts) This should be called from within a begin-commit-rollback block.void
commit()
Commits any changes done to the LuceneIndex since the last commit.The semantics is synchronous to SailConnection.commit(), i.e.protected SearchDocument
protected com.google.common.base.Function
<? super String, ? extends org.locationtech.spatial4j.context.SpatialContext> createSpatialContextMapper
(Map<String, String> parameters) protected void
protected Iterable
<? extends DocumentDistance> geoQuery
(IRI geoProperty, org.locationtech.spatial4j.shape.Point p, IRI units, double distance, String distanceVar, Var contextVar) protected Iterable
<? extends DocumentResult> geoRelationQuery
(String relation, IRI geoProperty, String wkt, Var contextVar) org.apache.solr.client.solrj.SolrClient
protected SearchDocument
getDocument
(String id) Returns a Document representing the specified document ID (combination of resource and context), or null when no such Document exists yet.getDocument
(Resource subject, Resource context) Returns a Document representing the specified Resource and Context combination, or null when no such Document exists yet.protected Iterable
<? extends SearchDocument> getDocuments
(String resourceId) Iterable
<? extends SearchDocument> getDocuments
(Resource subject) Returns a list of Documents representing the specified Resource (empty when no such Document exists yet).Each document represent a set of statements with the specified Resource as a subject, which are stored in a specific contextgetPropertyFields
(Set<String> fields) Filters the given list of fields, retaining all property fields.protected org.locationtech.spatial4j.context.SpatialContext
getSpatialContext
(String property) void
initialize
(Properties parameters) protected BulkUpdater
protected SearchDocument
newDocument
(String id, String resourceId, String context) protected org.locationtech.spatial4j.shape.Shape
parseQueryShape
(String property, String value) protected Iterable
<? extends DocumentScore> Parse the passed query.void
rollback()
org.apache.solr.client.solrj.response.QueryResponse
search
(org.apache.solr.client.solrj.SolrQuery query) Evaluates the given query and returns the results as a TopDocs instance.org.apache.solr.client.solrj.response.QueryResponse
Evaluates the given query only for the given resource.void
shutDown()
protected String
toWkt
(org.locationtech.spatial4j.shape.Shape s) protected void
Methods inherited from class org.eclipse.rdf4j.sail.lucene.AbstractSearchIndex
accept, addDocuments, addRemoveStatements, addStatement, evaluate, getIndexedTypeMapping, getResource, isGeoField, isIndexedTypeStatement, isTypeFilteringEnabled, isTypeStatement, parseLuceneQueryShape, parseQueryPoint, removeStatement
-
Field Details
-
SERVER_KEY
- See Also:
-
DISTANCE_FIELD
- See Also:
-
-
Constructor Details
-
SolrIndex
public SolrIndex()
-
-
Method Details
-
initialize
- Specified by:
initialize
in interfaceSearchIndex
- Overrides:
initialize
in classAbstractSearchIndex
- Throws:
Exception
-
createSpatialContextMapper
-
getClient
public org.apache.solr.client.solrj.SolrClient getClient() -
getSpatialContext
- Specified by:
getSpatialContext
in classAbstractSearchIndex
-
shutDown
- Throws:
IOException
-
getDocument
Returns a Document representing the specified document ID (combination of resource and context), or null when no such Document exists yet.- Specified by:
getDocument
in classAbstractSearchIndex
- Parameters:
id
-- Returns:
- search document
- Throws:
IOException
-
getDocuments
- Specified by:
getDocuments
in classAbstractSearchIndex
- Throws:
IOException
-
newDocument
- Specified by:
newDocument
in classAbstractSearchIndex
-
copyDocument
- Specified by:
copyDocument
in classAbstractSearchIndex
-
addDocument
- Specified by:
addDocument
in classAbstractSearchIndex
- Throws:
IOException
-
updateDocument
- Specified by:
updateDocument
in classAbstractSearchIndex
- Throws:
IOException
-
deleteDocument
- Specified by:
deleteDocument
in classAbstractSearchIndex
- Throws:
IOException
-
newBulkUpdate
- Specified by:
newBulkUpdate
in classAbstractSearchIndex
-
getDocument
Returns a Document representing the specified Resource and Context combination, or null when no such Document exists yet.- Parameters:
subject
-context
-- Returns:
- search document
- Throws:
IOException
-
getDocuments
Returns a list of Documents representing the specified Resource (empty when no such Document exists yet).Each document represent a set of statements with the specified Resource as a subject, which are stored in a specific context- Parameters:
subject
-- Returns:
- list of documents
- Throws:
IOException
-
getPropertyFields
-
begin
-
commit
Description copied from interface:SearchIndex
Commits any changes done to the LuceneIndex since the last commit.The semantics is synchronous to SailConnection.commit(), i.e. the LuceneIndex should be committed/rolled back whenever the LuceneSailConnection is committed/rolled back.- Throws:
IOException
-
rollback
- Throws:
IOException
-
query
protected Iterable<? extends DocumentScore> query(Resource subject, QuerySpec spec) throws MalformedQueryException, IOException Parse the passed query.- Specified by:
query
in classAbstractSearchIndex
- Parameters:
subject
-spec
- query to process- Returns:
- the parsed query
- Throws:
MalformedQueryException
IOException
IllegalArgumentException
- if the spec contains a multi-param query
-
search
public org.apache.solr.client.solrj.response.QueryResponse search(Resource resource, org.apache.solr.client.solrj.SolrQuery query) throws org.apache.solr.client.solrj.SolrServerException, IOException Evaluates the given query only for the given resource.- Parameters:
resource
-query
-- Returns:
- response
- Throws:
org.apache.solr.client.solrj.SolrServerException
IOException
-
geoQuery
protected Iterable<? extends DocumentDistance> geoQuery(IRI geoProperty, org.locationtech.spatial4j.shape.Point p, IRI units, double distance, String distanceVar, Var contextVar) throws MalformedQueryException, IOException - Specified by:
geoQuery
in classAbstractSearchIndex
- Throws:
MalformedQueryException
IOException
-
geoRelationQuery
protected Iterable<? extends DocumentResult> geoRelationQuery(String relation, IRI geoProperty, String wkt, Var contextVar) throws MalformedQueryException, IOException - Specified by:
geoRelationQuery
in classAbstractSearchIndex
- Throws:
MalformedQueryException
IOException
-
parseQueryShape
protected org.locationtech.spatial4j.shape.Shape parseQueryShape(String property, String value) throws ParseException - Overrides:
parseQueryShape
in classAbstractSearchIndex
- Throws:
ParseException
-
toWkt
-
search
public org.apache.solr.client.solrj.response.QueryResponse search(org.apache.solr.client.solrj.SolrQuery query) throws org.apache.solr.client.solrj.SolrServerException, IOException Evaluates the given query and returns the results as a TopDocs instance.- Parameters:
query
-- Returns:
- query response
- Throws:
org.apache.solr.client.solrj.SolrServerException
IOException
-
clearContexts
Description copied from interface:SearchIndex
This should be called from within a begin-commit-rollback block.- Parameters:
contexts
-- Throws:
IOException
-
clear
-