org.openrdf.sail.elasticsearch

Class ElasticsearchIndex

java.lang.Object

org.openrdf.sail.lucene.AbstractSearchIndex

org.openrdf.sail.elasticsearch.ElasticsearchIndex

All Implemented Interfaces:

SearchIndex

public class ElasticsearchIndex
extends AbstractSearchIndex

See Also:

LuceneSail

Field Summary

Fields

Modifier and Type	Field and Description
static String	DEFAULT_ANALYZER
static String	DEFAULT_DOCUMENT_TYPE
static String	DEFAULT_INDEX_NAME
static String	DOCUMENT_TYPE_KEY
static String	ELASTICSEARCH_KEY_PREFIX
static String	INDEX_NAME_KEY

Fields inherited from class org.openrdf.sail.lucene.AbstractSearchIndex

maxDocs

Constructor Summary

Constructors

Constructor and Description
ElasticsearchIndex()

Method Summary

Modifier and Type	Method and Description
protected void	addDocument(SearchDocument doc)
void	begin() Begins a transaction.
void	beginReading()
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.
protected SearchDocument	copyDocument(SearchDocument doc)
protected void	deleteDocument(SearchDocument doc)
void	endReading()
String	getClusterName()
SearchDocument	getDocument(Resource subject, Resource context) Returns a Document representing the specified Resource & Context combination, or null when no such Document exists yet.
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.
Iterable<? extends SearchDocument>	getDocuments(Resource subject) Returns a list of Documents representing the specified Resource (empty when no such Document exists yet).
protected Iterable<? extends SearchDocument>	getDocuments(String resourceId)
String	getIndexName()
Map<String,Object>	getMappings()
static List<String>	getPropertyFields(Collection<String> fields) Filters the given list of fields, retaining all property fields.
String[]	getTypes()
void	initialize(Properties parameters)
protected BulkUpdater	newBulkUpdate()
protected SearchDocument	newDocument(String id, String resourceId, String context)
protected SearchQuery	parseQuery(String query, URI propertyURI) Parse the passed query.
void	rollback()
org.elasticsearch.search.SearchHits	search(Resource resource, org.elasticsearch.action.search.SearchRequestBuilder request, org.elasticsearch.index.query.QueryBuilder query) Evaluates the given query only for the given resource.
org.elasticsearch.search.SearchHits	search(org.elasticsearch.action.search.SearchRequestBuilder request, org.elasticsearch.index.query.QueryBuilder query) Evaluates the given query and returns the results as a TopDocs instance.
void	shutDown()
protected void	updateDocument(SearchDocument doc)

Methods inherited from class org.openrdf.sail.lucene.AbstractSearchIndex

accept, addDocuments, addRemoveStatements, addStatement, evaluate, getResource, removeStatement

Methods inherited from class java.lang.Object

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

Field Detail

INDEX_NAME_KEY

public static final String INDEX_NAME_KEY

See Also:

Constant Field Values

DOCUMENT_TYPE_KEY

public static final String DOCUMENT_TYPE_KEY

See Also:

Constant Field Values

DEFAULT_INDEX_NAME

public static final String DEFAULT_INDEX_NAME

See Also:

Constant Field Values

DEFAULT_DOCUMENT_TYPE

public static final String DEFAULT_DOCUMENT_TYPE

See Also:

Constant Field Values

DEFAULT_ANALYZER

public static final String DEFAULT_ANALYZER

See Also:

Constant Field Values

ELASTICSEARCH_KEY_PREFIX

public static final String ELASTICSEARCH_KEY_PREFIX

See Also:

Constant Field Values

Constructor Detail

ElasticsearchIndex

public ElasticsearchIndex()

Method Detail

getClusterName

public String getClusterName()

getIndexName

public String getIndexName()

getTypes

public String[] getTypes()

initialize

public void initialize(Properties parameters)
                throws Exception

Specified by:

initialize in interface SearchIndex

Overrides:

initialize in class AbstractSearchIndex

Throws:

Exception

getMappings

public Map<String,Object> getMappings()
                               throws IOException

Throws:

IOException

shutDown

public void shutDown()
              throws IOException

Throws:

IOException

getDocument

protected SearchDocument getDocument(String id)
                              throws IOException

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 class AbstractSearchIndex

Throws:

IOException

getDocuments

protected Iterable<? extends SearchDocument> getDocuments(String resourceId)
                                                   throws IOException

Specified by:

getDocuments in class AbstractSearchIndex

Throws:

IOException

newDocument

protected SearchDocument newDocument(String id,
                                     String resourceId,
                                     String context)

Specified by:

newDocument in class AbstractSearchIndex

copyDocument

protected SearchDocument copyDocument(SearchDocument doc)

Specified by:

copyDocument in class AbstractSearchIndex

addDocument

protected void addDocument(SearchDocument doc)
                    throws IOException

Specified by:

addDocument in class AbstractSearchIndex

Throws:

IOException

updateDocument

protected void updateDocument(SearchDocument doc)
                       throws IOException

Specified by:

updateDocument in class AbstractSearchIndex

Throws:

IOException

deleteDocument

protected void deleteDocument(SearchDocument doc)
                       throws IOException

Specified by:

deleteDocument in class AbstractSearchIndex

Throws:

IOException

newBulkUpdate

protected BulkUpdater newBulkUpdate()

Specified by:

newBulkUpdate in class AbstractSearchIndex

getDocument

public SearchDocument getDocument(Resource subject,
                                  Resource context)
                           throws IOException

Returns a Document representing the specified Resource & Context combination, or null when no such Document exists yet.

Throws:

IOException

getDocuments

public Iterable<? extends SearchDocument> getDocuments(Resource subject)
                                                throws IOException

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

Throws:

IOException

getPropertyFields

public static List<String> getPropertyFields(Collection<String> fields)

Filters the given list of fields, retaining all property fields.

begin

public void begin()
           throws IOException

Description copied from interface: SearchIndex

Begins a transaction.

Throws:

IOException

commit

public void commit()
            throws IOException

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/rollbacked whenever the LuceneSailConnection is committed/rollbacked.

Throws:

IOException

rollback

public void rollback()
              throws IOException

Throws:

IOException

beginReading

public void beginReading()
                  throws IOException

Throws:

IOException

endReading

public void endReading()
                throws IOException

Throws:

IOException

parseQuery

protected SearchQuery parseQuery(String query,
                                 URI propertyURI)
                          throws MalformedQueryException

Parse the passed query.

Specified by:

parseQuery in class AbstractSearchIndex

Parameters:

query - string

Returns:

the parsed query

Throws:

ParseException - when the parsing brakes

MalformedQueryException

search

public org.elasticsearch.search.SearchHits search(Resource resource,
                                                  org.elasticsearch.action.search.SearchRequestBuilder request,
                                                  org.elasticsearch.index.query.QueryBuilder query)

Evaluates the given query only for the given resource.

search

public org.elasticsearch.search.SearchHits search(org.elasticsearch.action.search.SearchRequestBuilder request,
                                                  org.elasticsearch.index.query.QueryBuilder query)

Evaluates the given query and returns the results as a TopDocs instance.

clearContexts

public void clearContexts(Resource... contexts)
                   throws IOException

Description copied from interface: SearchIndex

This should be called from within a begin-commit-rollback block.

Parameters:

contexts -

sail - - the underlying native sail where to read the missing triples from after deletion

Throws:

SailException

IOException

clear

public void clear()
           throws IOException

Description copied from interface: SearchIndex

Clears the indexes.

Throws:

IOException