org.nuxeo.ecm.core.search.service
Class SearchServiceImpl

java.lang.Object
  org.nuxeo.runtime.model.DefaultComponent
      org.nuxeo.ecm.core.search.service.SearchServiceImpl

All Implemented Interfaces:

Serializable, SearchService, SearchServiceInternals, Adaptable, Component, Extensible

public class SearchServiceImpl
extends DefaultComponent
implements SearchServiceInternals

Nuxeo core search service implementation.

Author:

Julien Anguenot

See Also:

SearchService, Serialized Form

Field Summary

static int	DEFAULT_DOC_BATCH_SIZE
static int	DEFAULT_MAX_POOL_SIZE
static ComponentName	NAME

Fields inherited from interface org.nuxeo.ecm.core.search.api.client.SearchService

INDEXABLE_FACET

Constructor Summary

SearchServiceImpl()

Method Summary

void	clear() Completely erases the indexes.
void	closeSession(String sid) Closes a search service session given its identifier.
void	deleteAggregatedResources(String key) Deletes an index given an aggregated resources key
void	deleteAtomicResource(String key) Deletes an atomic resource given its key.
int	getActiveIndexingTasks() Returns the number of running indexing tasks.
String[]	getAvailableBackendNames() Returns the list of all backend names.
BlobExtractor	getBlobExtractorByName(String name) Returns a blob extractor given its name.
CoreSession	getCoreSession(String repoName)
protected SearchEngineBackend	getDefaultBackend() Returns the default backend registered for this search service instance.
String	getDefaultSearchEngineBakendName() Returns the default backend.
Set<String>	getDocumentTypeNamesExtending(String docType) Return the names of core document types extending the given one, which is included.
Set<String>	getDocumentTypeNamesForFacet(Collection<String> facets) Returns the set of document types bearing one of given facets.
Set<String>	getDocumentTypeNamesForFacet(String facet) Returns the set of document types bearing a given facet.
FulltextFieldDescriptor	getFullTextDescriptorByName(String name) Returns the full text descriptor given its name.
IndexableResourceDataConf	getIndexableDataConfByName(String name) Returns the indexing data conf by its name.
IndexableResourceDataConf	getIndexableDataConfFor(String dataName) Returns the indexing data conf for a given data name.
IndexableDocType	getIndexableDocTypeFor(String docType) Return the indexing information for a given nuxeo core doc type.
Map<String,IndexableDocType>	getIndexableDocTypes() Returns a map from doc type to indexable doc types.
IndexableResourceConf	getIndexableResourceConfByName(String name, boolean full) Returns an indexable resource configuration given its name.
IndexableResourceConf	getIndexableResourceConfByPrefix(String prefix, boolean full) Returns an indexable resource configuration given its prefix.
Map<String,IndexableResourceConf>	getIndexableResourceConfs() Returns all the indexable resource configurations registred.
int	getIndexingDocBatchSize() Returns the document batch size.
IndexingEventConf	getIndexingEventConfByName(String name) Returns an indexing event configuration given its name.
int	getNumberOfIndexingThreads() Returns the amount of threads the search service will be able to instanciate within its thread pool.
String	getPreferedBackendNameFor(ResolvedResource resource) Returns the prefered backend for an indexable resolved resource.
ResourceTypeDescriptor	getResourceTypeDescriptorByName(String name) Returns a resource type descriptor instance.
SearchEngineBackend	getSearchEngineBackendByName(String name) Returns a search engine plugin given its name.
Map<String,SearchEngineBackend>	getSearchEngineBackends() Returns registred search engine plugins.
SearchPrincipal	getSearchPrincipal(Principal principal) Computes a search principal out from a principal instance.
List<String>	getSupportedAnalyzersFor(String backendName) Returns the supported analyers for a given backend.
List<String>	getSupportedFieldTypes(String backendName) Returns the supported fieldd types for a given backend.
long	getTotalCompletedIndexingTasks() Returns the total number of completed indexing tasks.
void	index(IndexableResources sources, boolean fulltext) Add / update index(es) given an IndexableResources instance.
void	index(ResolvedResources sources) Ad / update index(es) given (ResolvedResources
void	indexInThread(DocumentModel dm, Boolean recursive, boolean fulltext) Add / index in a separated thread a document model instance.
void	indexInThread(ResolvedResources sources) Add / index in a separated thread a resolved resources.
void	invalidateComputedIndexableResourceConfs() Invalidates the computed indexable resource confs.
boolean	isEnabled() Is the search service enabled.
SearchServiceSession	openSession() Opens a new session against the search service.
void	registerContribution(Object contribution, String extensionPoint, ComponentInstance contributor)
void	reindexAll(String repoName, String path, boolean fulltext) Perform a full reindexing of the nuxeo core repository given a Nuxeo core repository name and a path.
void	saveAllSessions() Save all pending sessions.
ResultSet	searchQuery(ComposedNXQuery nxqlQuery, int offset, int range) Searches results given an NXQL query.
ResultSet	searchQuery(NativeQuery nativeQuery, int offset, int range) Searches results given a backend native query wrapper.
ResultSet	searchQuery(NativeQueryString queryString, String backendName, int offset, int range) Searches results given a backend native query string.
void	setDefaultSearchEngineBackendName(String backendName) Sets the default backend given its name.
void	setIndexingDocBatchSize(int docBatchSize) Sets the document batch size.
void	setNumberOfIndexingThreads(int numberOfIndexingThreads) Sets the amount of threads the search service will be able to instanciate within its thread pool.
void	setStatus(boolean active) Set the status of the search service.
void	unregisterContribution(Object contribution, String extensionPoint, ComponentInstance contributor)

Methods inherited from class org.nuxeo.runtime.model.DefaultComponent

activate, deactivate, getAdapter, registerExtension, unregisterExtension

Methods inherited from class java.lang.Object

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

Field Detail

NAME

public static final ComponentName NAME

DEFAULT_MAX_POOL_SIZE

public static final int DEFAULT_MAX_POOL_SIZE

See Also:

Constant Field Values

DEFAULT_DOC_BATCH_SIZE

public static final int DEFAULT_DOC_BATCH_SIZE

See Also:

Constant Field Values

Constructor Detail

SearchServiceImpl

public SearchServiceImpl()

Method Detail

getDefaultSearchEngineBakendName

public final String getDefaultSearchEngineBakendName()

Description copied from interface: SearchServiceInternals

Returns the default backend.

It will be used as a fallback when no prefered backend are specified by a given resource.

Note, this is the backend responsability to register itself as default. And as well, the default backend can be overriden by another contributed backend. In this case, one can use the deployment order offered by Nuxeo runtime to ensure priority.

Returns null if no default backend registered.

Specified by:

getDefaultSearchEngineBakendName in interface SearchServiceInternals

Returns:

a search engine backend instance

setDefaultSearchEngineBackendName

public final void setDefaultSearchEngineBackendName(String backendName)

Description copied from interface: SearchServiceInternals

Sets the default backend given its name.

Specified by:

setDefaultSearchEngineBackendName in interface SearchServiceInternals

Parameters:

backendName - a search engine backend instance.

getPreferedBackendNameFor

public final String getPreferedBackendNameFor(ResolvedResource resource)

Description copied from interface: SearchServiceInternals

Returns the prefered backend for an indexable resolved resource.

Specified by:

getPreferedBackendNameFor in interface SearchServiceInternals

Parameters:

resource - an indexable resolved resource.

Returns:

a backend name.

getDefaultBackend

protected SearchEngineBackend getDefaultBackend()

Returns the default backend registered for this search service instance.

Returns:

a SearchEngineBackend instance

index

public void index(ResolvedResources sources)
           throws IndexingException

Description copied from interface: SearchService

Ad / update index(es) given (ResolvedResources

This method is useful to perform the resource resolution outside the search service.

Specified by:

index in interface SearchService

Parameters:

sources - : resolved resources

Throws:

IndexingException - wrap low level backend exception

index

public void index(IndexableResources sources,
                  boolean fulltext)
           throws IndexingException

Description copied from interface: SearchService

Add / update index(es) given an IndexableResources instance.

The actual resolution in this case will be done search service side.

Specified by:

index in interface SearchService

Parameters:

sources - : an IndexableResources instance

fulltext - : do compute fulltext at resolution time.

Throws:

IndexingException - wrap low level backend exception

clear

public void clear()
           throws IndexingException

Description copied from interface: SearchService

Completely erases the indexes.

Specified by:

clear in interface SearchService

Throws:

IndexingException

deleteAggregatedResources

public void deleteAggregatedResources(String key)
                               throws IndexingException

Description copied from interface: SearchService

Deletes an index given an aggregated resources key

This will remove all resources indexed with key as key used to identified the set ot resources. See ResolvedResources.getId()

Specified by:

deleteAggregatedResources in interface SearchService

Parameters:

key - : aggregated resources key.

Throws:

IndexingException

deleteAtomicResource

public void deleteAtomicResource(String key)
                          throws IndexingException

Description copied from interface: SearchService

Deletes an atomic resource given its key.

This will remove the resource identified by this resource key only.

Specified by:

deleteAtomicResource in interface SearchService

Parameters:

key - : atomic resource key

Throws:

IndexingException

getSearchEngineBackendByName

public final SearchEngineBackend getSearchEngineBackendByName(String name)

Description copied from interface: SearchServiceInternals

Returns a search engine plugin given its name.

Specified by:

getSearchEngineBackendByName in interface SearchServiceInternals

Parameters:

name - : name of the search engine plugin.

Returns:

a search engine backend instance

getSearchEngineBackends

public final Map<String,SearchEngineBackend> getSearchEngineBackends()

Description copied from interface: SearchServiceInternals

Returns registred search engine plugins.

Specified by:

getSearchEngineBackends in interface SearchServiceInternals

Returns:

registred search engine plugins.

registerContribution

public void registerContribution(Object contribution,
                                 String extensionPoint,
                                 ComponentInstance contributor)

Overrides:

registerContribution in class DefaultComponent

unregisterContribution

public void unregisterContribution(Object contribution,
                                   String extensionPoint,
                                   ComponentInstance contributor)

Overrides:

unregisterContribution in class DefaultComponent

getIndexableResourceConfByName

public final IndexableResourceConf getIndexableResourceConfByName(String name,
                                                                  boolean full)

Description copied from interface: SearchService

Returns an indexable resource configuration given its name.

Specified by:

getIndexableResourceConfByName in interface SearchService

Parameters:

name - : the name of the indexable resource configuration.

full - : compute automatic configuration to get the full resource configuration

Returns:

an indexable resource configuration instance given its name.

getIndexableResourceConfByPrefix

public final IndexableResourceConf getIndexableResourceConfByPrefix(String prefix,
                                                                    boolean full)

Description copied from interface: SearchService

Returns an indexable resource configuration given its prefix.

Specified by:

getIndexableResourceConfByPrefix in interface SearchService

Parameters:

prefix - : the prefix of the indexable resource configuration.

full - compute automatic configuration to get the full resource configuration

Returns:

an indexable resource configuration instance given its name.

getIndexableResourceConfs

public final Map<String,IndexableResourceConf> getIndexableResourceConfs()

Description copied from interface: SearchService

Returns all the indexable resource configurations registred.

Specified by:

getIndexableResourceConfs in interface SearchService

Returns:

the a map from indexable resource configuration name to indexable resource configuration instance.

getIndexableDocTypes

public final Map<String,IndexableDocType> getIndexableDocTypes()

Description copied from interface: SearchServiceInternals

Returns a map from doc type to indexable doc types.

Specified by:

getIndexableDocTypes in interface SearchServiceInternals

Returns:

a map from doc type to indexable doc type.

getIndexableDocTypeFor

public final IndexableDocType getIndexableDocTypeFor(String docType)

Description copied from interface: SearchService

Return the indexing information for a given nuxeo core doc type.

Specified by:

getIndexableDocTypeFor in interface SearchService

Parameters:

docType - : doc type indentifier.

Returns:

an indexable doc type instance.

getSupportedAnalyzersFor

public List<String> getSupportedAnalyzersFor(String backendName)

Description copied from interface: SearchService

Returns the supported analyers for a given backend.

Specified by:

getSupportedAnalyzersFor in interface SearchService

Parameters:

backendName - : the backend name.

Returns:

a list of identifiers.

getSupportedFieldTypes

public List<String> getSupportedFieldTypes(String backendName)

Description copied from interface: SearchService

Returns the supported fieldd types for a given backend.

Specified by:

getSupportedFieldTypes in interface SearchService

Parameters:

backendName - : the backend name.

Returns:

a list of identifiers.

searchQuery

public ResultSet searchQuery(ComposedNXQuery nxqlQuery,
                             int offset,
                             int range)
                      throws SearchException,
                             QueryException

Description copied from interface: SearchService

Searches results given an NXQL query.

Specified by:

searchQuery in interface SearchService

offset - : pagination start

range - : number of results.

Returns:

a ResultSet instance.

Throws:

SearchException - wrap low level backend exception

QueryException - if the query is invalid or unsupported

searchQuery

public ResultSet searchQuery(NativeQuery nativeQuery,
                             int offset,
                             int range)
                      throws SearchException,
                             QueryException

Description copied from interface: SearchService

Searches results given a backend native query wrapper.

Specified by:

searchQuery in interface SearchService

Parameters:

nativeQuery - : the backend native query wrapper.

offset - : pagination start

range - : number of results.

Returns:

a result set instance

Throws:

SearchException - wrap low level backend exception

QueryException - if the query is invalid or unsupported

searchQuery

public ResultSet searchQuery(NativeQueryString queryString,
                             String backendName,
                             int offset,
                             int range)
                      throws SearchException,
                             QueryException

Description copied from interface: SearchService

Searches results given a backend native query string.

Specified by:

searchQuery in interface SearchService

Parameters:

queryString - : the backend native query string wrapper.

backendName - the backened name to apply the query on. If backened name is null then use the default indexing backends

offset - : pagination start

range - : number of results.

Returns:

a result set instance

Throws:

SearchException - wrap low level backend exception

QueryException - wrong query, rewrapped from backend

getAvailableBackendNames

public final String[] getAvailableBackendNames()

Description copied from interface: SearchService

Returns the list of all backend names.

Specified by:

getAvailableBackendNames in interface SearchService

Returns:

the list of all backend names.

getIndexableDataConfFor

public final IndexableResourceDataConf getIndexableDataConfFor(String dataName)

Description copied from interface: SearchServiceInternals

Returns the indexing data conf for a given data name.

For instance, a data name can be dc:title

Specified by:

getIndexableDataConfFor in interface SearchServiceInternals

Parameters:

dataName - the data name.

Returns:

an indexable resource data conf.

getIndexableDataConfByName

public final IndexableResourceDataConf getIndexableDataConfByName(String name)

Description copied from interface: SearchServiceInternals

Returns the indexing data conf by its name.

TODO This is a temporary helper for the current flat data model To be rethought

For instance, the name can be Title while the data name is dublincore:title.

Specified by:

getIndexableDataConfByName in interface SearchServiceInternals

Parameters:

name - the data name.

Returns:

an indexable resource data conf.

getSearchPrincipal

public final SearchPrincipal getSearchPrincipal(Principal principal)

Description copied from interface: SearchService

Computes a search principal out from a principal instance.

NuxeoPrincipal instance is expected for groups support.

Specified by:

getSearchPrincipal in interface SearchService

Parameters:

principal - : a java principal instance

Returns:

a search principal instance

isEnabled

public final boolean isEnabled()

Description copied from interface: SearchService

Is the search service enabled.

Possible to disable the search service using extension point parameter.

Specified by:

isEnabled in interface SearchService

Returns:

true if active / false if inactive.

setStatus

public final void setStatus(boolean active)

Description copied from interface: SearchService

Set the status of the search service.

Specified by:

setStatus in interface SearchService

Parameters:

active - : if active is true then the service will be activated

getFullTextDescriptorByName

public final FulltextFieldDescriptor getFullTextDescriptorByName(String name)

Description copied from interface: SearchService

Returns the full text descriptor given its name.

Specified by:

getFullTextDescriptorByName in interface SearchService

Parameters:

name - : the prefixed name with what it's been registered using extension point.

Returns:

a full text field descriptor.

getIndexingEventConfByName

public IndexingEventConf getIndexingEventConfByName(String name)

Description copied from interface: SearchService

Returns an indexing event configuration given its name.

Specified by:

getIndexingEventConfByName in interface SearchService

Parameters:

name - : the name under which it's been registered using extension point.

Returns:

the configuration object.

getDocumentTypeNamesForFacet

public final Set<String> getDocumentTypeNamesForFacet(String facet)

Description copied from interface: SearchServiceInternals

Returns the set of document types bearing a given facet.

Specified by:

getDocumentTypeNamesForFacet in interface SearchServiceInternals

Parameters:

facet - the given facet

Returns:

the set of names, guaranteed to be non empty, or null

getDocumentTypeNamesExtending

public Set<String> getDocumentTypeNamesExtending(String docType)

Description copied from interface: SearchServiceInternals

Return the names of core document types extending the given one, which is included.

Specified by:

getDocumentTypeNamesExtending in interface SearchServiceInternals

Parameters:

docType - the base document type.

Returns:

the names as a set or null

getDocumentTypeNamesForFacet

public final Set<String> getDocumentTypeNamesForFacet(Collection<String> facets)

Description copied from interface: SearchServiceInternals

Returns the set of document types bearing one of given facets.

Specified by:

getDocumentTypeNamesForFacet in interface SearchServiceInternals

Parameters:

facets - the given facets, as a collection

Returns:

the set of names, guaranteed to be non empty, or null

invalidateComputedIndexableResourceConfs

public final void invalidateComputedIndexableResourceConfs()

Description copied from interface: SearchService

Invalidates the computed indexable resource confs.

Will be useful if Nuxeo Runtime supports hot deployment in the future.

Specified by:

invalidateComputedIndexableResourceConfs in interface SearchService

getBlobExtractorByName

public final BlobExtractor getBlobExtractorByName(String name)

Description copied from interface: SearchService

Returns a blob extractor given its name.

Specified by:

getBlobExtractorByName in interface SearchService

Parameters:

name - : the name against which the full text extractor has been registered using extension point.

Returns:

getResourceTypeDescriptorByName

public ResourceTypeDescriptor getResourceTypeDescriptorByName(String name)

Description copied from interface: SearchService

Returns a resource type descriptor instance.

Specified by:

getResourceTypeDescriptorByName in interface SearchService

Parameters:

name - : the resource type name which has been used with extension point.

Returns:

a resource type descriptor instance

getNumberOfIndexingThreads

public int getNumberOfIndexingThreads()

Description copied from interface: SearchService

Returns the amount of threads the search service will be able to instanciate within its thread pool.

Specified by:

getNumberOfIndexingThreads in interface SearchService

Returns:

the number of threads max

indexInThread

public void indexInThread(DocumentModel dm,
                          Boolean recursive,
                          boolean fulltext)
                   throws IndexingException

Description copied from interface: SearchService

Add / index in a separated thread a document model instance.

We need to invoke the service to reach the thread pool as the ppol

Specified by:

indexInThread in interface SearchService

Parameters:

dm - : a Nuxeo Core document model instance.

recursive - : perform an indexing recursion on this document model children

fulltext - : Do compute fulltext along with other metadata.

Throws:

IndexingException - : in case of thread pool internal error.

closeSession

public void closeSession(String sid)

Description copied from interface: SearchService

Closes a search service session given its identifier.

Specified by:

closeSession in interface SearchService

Parameters:

sid - : the search service identifier

openSession

public SearchServiceSession openSession()

Description copied from interface: SearchService

Opens a new session against the search service.

Attention, for now the client is responsible of the session closure...

Specified by:

openSession in interface SearchService

Returns:

a search service session.

getIndexingDocBatchSize

public int getIndexingDocBatchSize()

Description copied from interface: SearchService

Returns the document batch size.

In case of batch indexing we can choose to save the indexing session for a given amount of document. Default is one meaning the session is saved after every insertion. You might want to increase this while performing bulk document imports.

Specified by:

getIndexingDocBatchSize in interface SearchService

Returns:

number of of document per indexing session before save()

setIndexingDocBatchSize

public void setIndexingDocBatchSize(int docBatchSize)

Description copied from interface: SearchService

Sets the document batch size.

In case of batch indexing we can choose to save the indexing session for a given amount of document. Default is one meaning the session is saved after every insertion. You might want to increase this while performing bulk document imports.

Specified by:

setIndexingDocBatchSize in interface SearchService

Parameters:

docBatchSize - : number of of document per indexing session before save()

setNumberOfIndexingThreads

public void setNumberOfIndexingThreads(int numberOfIndexingThreads)

Description copied from interface: SearchService

Sets the amount of threads the search service will be able to instanciate within its thread pool.

Specified by:

setNumberOfIndexingThreads in interface SearchService

Parameters:

numberOfIndexingThreads - : the number of threads max

saveAllSessions

public void saveAllSessions()
                     throws IndexingException

Description copied from interface: SearchService

Save all pending sessions.

This is useful when using document batch size greater than 1 since if the amount of documents indexed are not an exact multiple of the document batch size then one might want to flush right now on demande the remaning resources in sessions before the next window size is reached.

Specified by:

saveAllSessions in interface SearchService

Throws:

IndexingException

getCoreSession

public CoreSession getCoreSession(String repoName)
                           throws IndexingException

Throws:

IndexingException

reindexAll

public void reindexAll(String repoName,
                       String path,
                       boolean fulltext)
                throws IndexingException

Description copied from interface: SearchService

Perform a full reindexing of the nuxeo core repository given a Nuxeo core repository name and a path.

If path is null then the reindexing will be done from the root of the repository (i.e : "/")

Specified by:

reindexAll in interface SearchService

Parameters:

repoName - : the Nuxeo Core repository name.

fulltext - : whether or not we want to index fulltext.

Throws:

IndexingException

getActiveIndexingTasks

public int getActiveIndexingTasks()

Description copied from interface: SearchService

Returns the number of running indexing tasks.

Specified by:

getActiveIndexingTasks in interface SearchService

Returns:

the number of actively running indexing tasks

getTotalCompletedIndexingTasks

public long getTotalCompletedIndexingTasks()

Description copied from interface: SearchService

Returns the total number of completed indexing tasks.

If you wanna use this API for monitoring purpose, you should be aware that the total number of indexing tasks is reinitialized when the component is loaded only. Thus you should keep track of this value before performing your indexing operation you want to keep track of.

Specified by:

getTotalCompletedIndexingTasks in interface SearchService

Returns:

the total number of commpleted indexing tasks.

indexInThread

public void indexInThread(ResolvedResources sources)
                   throws IndexingException

Description copied from interface: SearchService

Add / index in a separated thread a resolved resources.

We need to invoke the service to reach the thread pool as the ppol

Specified by:

indexInThread in interface SearchService

Parameters:

sources - : resolved resources

Throws:

IndexingException - : in case of thread pool internal error.