org.nuxeo.elasticsearch

Class ElasticSearchComponent

java.lang.Object

org.nuxeo.runtime.model.DefaultComponent

org.nuxeo.elasticsearch.ElasticSearchComponent

All Implemented Interfaces:

ElasticSearchAdmin, ElasticSearchIndexing, ElasticSearchService, Adaptable, Component, Extensible, TimestampedService

public class ElasticSearchComponent
extends DefaultComponent
implements ElasticSearchAdmin, ElasticSearchIndexing, ElasticSearchService

Component used to configure and manage ElasticSearch integration

Constructor Summary

Constructors

Constructor and Description
ElasticSearchComponent()

Method Summary

Methods

Modifier and Type	Method and Description
void	applicationStarted(ComponentContext context) Notify the component that Nuxeo Framework finished starting all Nuxeo bundles.
void	deactivate(ComponentContext context) Deactivates the component.
void	dropAndInitRepositoryIndex(String repositoryName) Reinitialize the index of a repository.
void	flush() Elasticsearch flush on all document indexes, triggers a lucene commit, empties the transaction log.
void	flushRepositoryIndex(String repositoryName) Elasticsearch flush on document index for a specific repository, triggers a lucene commit, empties the transaction log.
int	getApplicationStartedOrder() The component notification order for Component.applicationStarted(org.nuxeo.runtime.model.ComponentContext).
org.elasticsearch.client.Client	getClient() Retrieves the Client that can be used to access Elasticsearch API
String	getIndexNameForRepository(String repositoryName) Get the index name associated with the repository name.
int	getPendingCommandCount() Returns the number of command scheduled for indexing.
int	getPendingWorkerCount() Returns the number of indexing worker pending waiting to be executed.
List<String>	getRepositoryNames() List repository names that have Elasticsearch support.
int	getRunningWorkerCount() Returns the number of indexing worker that are currently running.
int	getTotalCommandProcessed() Returns the total number of command processed by Elasticsearch.
void	indexNonRecursive(IndexingCommand cmd) Process the IndexingCommand.
void	indexNonRecursive(List<IndexingCommand> cmds) Same as ElasticSearchIndexing.indexNonRecursive(org.nuxeo.elasticsearch.commands.IndexingCommand) but process the list command using a bulk request.
void	initIndexes(boolean dropIfExists) Initialize Elasticsearch indexes.
boolean	isAlreadyScheduled(IndexingCommand cmd) {true} if a command has already been submitted for indexing.
boolean	isEmbedded() Returns true if the Elasticsearch is embedded with Nuxeo, sharing the same JVM.
boolean	isIndexingInProgress() Returns true if there are indexing activities scheduled or running.
void	optimize() Elasticsearch run ElasticSearchAdmin.optimizeRepositoryIndex(java.lang.String) on all document indexes,
void	optimizeRepositoryIndex(String repositoryName) Elasticsearch optimize operation allows to reduce the number of segments to one, Note that this can potentially be a very heavy operation.
com.google.common.util.concurrent.ListenableFuture<Boolean>	prepareWaitForIndexing() A Future that accepts callback on completion when all the indexing worker are done.
DocumentModelList	query(CoreSession session, org.elasticsearch.index.query.QueryBuilder queryBuilder, int limit, int offset, SortInfo... sortInfos) Deprecated.
DocumentModelList	query(CoreSession session, String nxql, int limit, int offset, SortInfo... sortInfos) Deprecated.
DocumentModelList	query(NxQueryBuilder queryBuilder) Returns a document list using an NxQueryBuilder.
EsResult	queryAndAggregate(NxQueryBuilder queryBuilder) Returns documents and aggregates.
void	refresh() Refresh all document indexes, immediately after the operation occurs, so that the updated document appears in search results immediately.
void	refreshRepositoryIndex(String repositoryName) Refresh document index for the specific repository, immediately after the operation occurs, so that the updated document appears in search results immediately.
void	registerContribution(Object contribution, String extensionPoint, ComponentInstance contributor)
void	runIndexingWorker(List<IndexingCommand> cmds) Run a worker to process the IndexingCommand.
void	runReindexingWorker(String repositoryName, String nxql) Reindex documents matching the NXQL query, This is asynchronous.

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

activate, getAdapter, getLastModified, registerExtension, setLastModified, unregisterContribution, unregisterExtension

Methods inherited from class java.lang.Object

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

Constructor Detail

ElasticSearchComponent

public ElasticSearchComponent()

Method Detail

registerContribution

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

Overrides:

registerContribution in class DefaultComponent

applicationStarted

public void applicationStarted(ComponentContext context)

Description copied from interface: Component

Notify the component that Nuxeo Framework finished starting all Nuxeo bundles.

Specified by:

applicationStarted in interface Component

Overrides:

applicationStarted in class DefaultComponent

deactivate

public void deactivate(ComponentContext context)

Description copied from interface: Component

Deactivates the component.

This method is called by the runtime when a component is deactivated.

Specified by:

deactivate in interface Component

Overrides:

deactivate in class DefaultComponent

Parameters:

context - the runtime context

getApplicationStartedOrder

public int getApplicationStartedOrder()

Description copied from interface: Component

The component notification order for Component.applicationStarted(org.nuxeo.runtime.model.ComponentContext).

Components are notified in increasing order. Order 1000 is the default order for components that don't care. Order 100 is the repository initialization.

Specified by:

getApplicationStartedOrder in interface Component

Overrides:

getApplicationStartedOrder in class DefaultComponent

Returns:

the order, 1000 by default

getClient

public org.elasticsearch.client.Client getClient()

Description copied from interface: ElasticSearchAdmin

Retrieves the Client that can be used to access Elasticsearch API

Specified by:

getClient in interface ElasticSearchAdmin

initIndexes

public void initIndexes(boolean dropIfExists)

Description copied from interface: ElasticSearchAdmin

Initialize Elasticsearch indexes. Setup the index settings and mapping for each index that has been registered.

Specified by:

initIndexes in interface ElasticSearchAdmin

Parameters:

dropIfExists - if {true} remove an existing index

dropAndInitRepositoryIndex

public void dropAndInitRepositoryIndex(String repositoryName)

Description copied from interface: ElasticSearchAdmin

Reinitialize the index of a repository. This will drop the existing index, recreate it with its settings and mapping, the index will be empty.

Specified by:

dropAndInitRepositoryIndex in interface ElasticSearchAdmin

getRepositoryNames

public List<String> getRepositoryNames()

Description copied from interface: ElasticSearchAdmin

List repository names that have Elasticsearch support.

Specified by:

getRepositoryNames in interface ElasticSearchAdmin

getIndexNameForRepository

public String getIndexNameForRepository(String repositoryName)

Description copied from interface: ElasticSearchAdmin

Get the index name associated with the repository name. throws NoSuchElementException if there is no Elasticsearch index associated with the requested repository.

Specified by:

getIndexNameForRepository in interface ElasticSearchAdmin

getPendingCommandCount

public int getPendingCommandCount()

Description copied from interface: ElasticSearchAdmin

Returns the number of command scheduled for indexing.

Specified by:

getPendingCommandCount in interface ElasticSearchAdmin

getPendingWorkerCount

public int getPendingWorkerCount()

Description copied from interface: ElasticSearchAdmin

Returns the number of indexing worker pending waiting to be executed.

Specified by:

getPendingWorkerCount in interface ElasticSearchAdmin

getRunningWorkerCount

public int getRunningWorkerCount()

Description copied from interface: ElasticSearchAdmin

Returns the number of indexing worker that are currently running.

Specified by:

getRunningWorkerCount in interface ElasticSearchAdmin

getTotalCommandProcessed

public int getTotalCommandProcessed()

Description copied from interface: ElasticSearchAdmin

Returns the total number of command processed by Elasticsearch. Useful for test assertion.

Specified by:

getTotalCommandProcessed in interface ElasticSearchAdmin

isEmbedded

public boolean isEmbedded()

Description copied from interface: ElasticSearchAdmin

Returns true if the Elasticsearch is embedded with Nuxeo, sharing the same JVM.

Specified by:

isEmbedded in interface ElasticSearchAdmin

isIndexingInProgress

public boolean isIndexingInProgress()

Description copied from interface: ElasticSearchAdmin

Returns true if there are indexing activities scheduled or running.

Specified by:

isIndexingInProgress in interface ElasticSearchAdmin

prepareWaitForIndexing

public com.google.common.util.concurrent.ListenableFuture<Boolean> prepareWaitForIndexing()

Description copied from interface: ElasticSearchAdmin

A Future that accepts callback on completion when all the indexing worker are done.

Specified by:

prepareWaitForIndexing in interface ElasticSearchAdmin

refresh

public void refresh()

Description copied from interface: ElasticSearchAdmin

Refresh all document indexes, immediately after the operation occurs, so that the updated document appears in search results immediately. There is no fsync thus doesn't guarantee durability.

Specified by:

refresh in interface ElasticSearchAdmin

refreshRepositoryIndex

public void refreshRepositoryIndex(String repositoryName)

Description copied from interface: ElasticSearchAdmin

Refresh document index for the specific repository, immediately after the operation occurs, so that the updated document appears in search results immediately. There is no fsync thus doesn't guarantee durability.

Specified by:

refreshRepositoryIndex in interface ElasticSearchAdmin

flush

public void flush()

Description copied from interface: ElasticSearchAdmin

Elasticsearch flush on all document indexes, triggers a lucene commit, empties the transaction log. Data is flushed to disk.

Specified by:

flush in interface ElasticSearchAdmin

flushRepositoryIndex

public void flushRepositoryIndex(String repositoryName)

Description copied from interface: ElasticSearchAdmin

Elasticsearch flush on document index for a specific repository, triggers a lucene commit, empties the transaction log. Data is flushed to disk.

Specified by:

flushRepositoryIndex in interface ElasticSearchAdmin

optimize

public void optimize()

Description copied from interface: ElasticSearchAdmin

Elasticsearch run ElasticSearchAdmin.optimizeRepositoryIndex(java.lang.String) on all document indexes,

Specified by:

optimize in interface ElasticSearchAdmin

optimizeRepositoryIndex

public void optimizeRepositoryIndex(String repositoryName)

Description copied from interface: ElasticSearchAdmin

Elasticsearch optimize operation allows to reduce the number of segments to one, Note that this can potentially be a very heavy operation.

Specified by:

optimizeRepositoryIndex in interface ElasticSearchAdmin

isAlreadyScheduled

public boolean isAlreadyScheduled(IndexingCommand cmd)

Description copied from interface: ElasticSearchIndexing

{true} if a command has already been submitted for indexing.

Specified by:

isAlreadyScheduled in interface ElasticSearchIndexing

indexNonRecursive

public void indexNonRecursive(IndexingCommand cmd)
                       throws ClientException

Description copied from interface: ElasticSearchIndexing

Process the IndexingCommand.

Send indexing command to Elasticsearch, if the command is synchronous the index is refreshed so the document is searchable immediately. Recursive indexing is not taken in account except for deletion. This is not a transactional operation, a rollback will not discard the executed commands.

Specified by:

indexNonRecursive in interface ElasticSearchIndexing

Throws:

ClientException

indexNonRecursive

public void indexNonRecursive(List<IndexingCommand> cmds)
                       throws ClientException

Description copied from interface: ElasticSearchIndexing

Same as ElasticSearchIndexing.indexNonRecursive(org.nuxeo.elasticsearch.commands.IndexingCommand) but process the list command using a bulk request.

Specified by:

indexNonRecursive in interface ElasticSearchIndexing

Throws:

ClientException

runIndexingWorker

public void runIndexingWorker(List<IndexingCommand> cmds)

Description copied from interface: ElasticSearchIndexing

Run a worker to process the IndexingCommand.

Asynchronous command schedules an indexing job and return.

Synchronous command execute an indexing job using a new Tx then refresh the index so the document is searchable immediately. if the command is also recursive the children are processed asynchronously.

If there is more than one cmd the elasticsearch request is done in bulk mode.

Specified by:

runIndexingWorker in interface ElasticSearchIndexing

runReindexingWorker

public void runReindexingWorker(String repositoryName,
                       String nxql)

Description copied from interface: ElasticSearchIndexing

Reindex documents matching the NXQL query, This is asynchronous.

Specified by:

runReindexingWorker in interface ElasticSearchIndexing

query

public DocumentModelList query(NxQueryBuilder queryBuilder)
                        throws ClientException

Description copied from interface: ElasticSearchService

Returns a document list using an NxQueryBuilder.

Specified by:

query in interface ElasticSearchService

Throws:

ClientException

queryAndAggregate

public EsResult queryAndAggregate(NxQueryBuilder queryBuilder)
                           throws ClientException

Description copied from interface: ElasticSearchService

Returns documents and aggregates.

Specified by:

queryAndAggregate in interface ElasticSearchService

Throws:

ClientException

query

@Deprecated
public DocumentModelList query(CoreSession session,
                                 String nxql,
                                 int limit,
                                 int offset,
                                 SortInfo... sortInfos)
                        throws ClientException

Deprecated.

Description copied from interface: ElasticSearchService

Returns a document list using an NXQL query. Fetch documents from the VCS repository.

Specified by:

query in interface ElasticSearchService

Throws:

ClientException

query

@Deprecated
public DocumentModelList query(CoreSession session,
                                 org.elasticsearch.index.query.QueryBuilder queryBuilder,
                                 int limit,
                                 int offset,
                                 SortInfo... sortInfos)
                        throws ClientException

Deprecated.

Description copied from interface: ElasticSearchService

Returns a document list using an ElasticSearch QueryBuilder. Fetch documents from the VCS repository.

Specified by:

query in interface ElasticSearchService

Throws:

ClientException