public interface ElasticSearchAdmin
Modifier and Type | Method and Description |
---|---|
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.
|
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 |
initIndexes(boolean dropIfExists)
Initialize Elasticsearch indexes.
|
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
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. |
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.
|
org.elasticsearch.client.Client getClient()
Client
that can be used to access Elasticsearch APIvoid initIndexes(boolean dropIfExists)
dropIfExists
- if {true} remove an existing indexvoid dropAndInitRepositoryIndex(String repositoryName)
List<String> getRepositoryNames()
String getIndexNameForRepository(String repositoryName)
boolean isIndexingInProgress()
com.google.common.util.concurrent.ListenableFuture<Boolean> prepareWaitForIndexing()
Future
that accepts callback on completion when all the indexing
worker are done.void refresh()
void refreshRepositoryIndex(String repositoryName)
void flush()
void flushRepositoryIndex(String repositoryName)
void optimize()
optimizeRepositoryIndex(java.lang.String)
on all document indexes,void optimizeRepositoryIndex(String repositoryName)
int getPendingCommandCount()
int getPendingWorkerCount()
int getRunningWorkerCount()
int getTotalCommandProcessed()
boolean isEmbedded()
Copyright © 2015 Nuxeo SA. All rights reserved.