public class ElasticSearchAdminImpl extends Object implements ElasticSearchAdmin
Modifier and Type | Field and Description |
---|---|
protected ESClient |
client |
protected ElasticSearchClientConfig |
clientConfig |
protected ElasticSearchEmbeddedNode |
embeddedServer |
protected ElasticSearchEmbeddedServerConfig |
embeddedServerConfig |
protected String[] |
excludeSourceFields |
protected String[] |
includeSourceFields |
protected Map<String,ElasticSearchIndexConfig> |
indexConfig |
protected boolean |
indexInitDone |
protected Map<String,String> |
indexNames |
protected Map<String,String> |
repoNames |
protected List<String> |
repositoryInitialized |
protected static int |
TIMEOUT_DELETE_SECOND |
protected static int |
TIMEOUT_WAIT_FOR_CLUSTER_SECOND |
protected AtomicInteger |
totalCommandProcessed |
protected Map<String,String> |
writeIndexNames |
Constructor and Description |
---|
ElasticSearchAdminImpl(ElasticSearchEmbeddedServerConfig embeddedServerConfig,
ElasticSearchClientConfig clientConfig,
Map<String,ElasticSearchIndexConfig> indexConfig)
Init the admin service, remote configuration if not null will take precedence over local embedded configuration.
|
Modifier and Type | Method and Description |
---|---|
protected void |
checkClusterHealth(String... indexNames) |
protected void |
checkConfig() |
protected void |
connect() |
protected ESClient |
createClient(ElasticSearchEmbeddedNode node) |
void |
disconnect() |
void |
dropAndInitIndex(String indexName)
Reinitialize an index.
|
void |
dropAndInitRepositoryIndex(String repositoryName,
boolean syncAlias)
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.
|
ESClient |
getClient()
Retrieves the
Client that can be used to access Elasticsearch API |
protected String[] |
getExcludeSourceFields() |
protected String[] |
getIncludeSourceFields() |
String |
getIndexNameForRepository(String repositoryName)
Get the search index name associated with the repository name.
|
String |
getIndexNameForType(String type)
Get the first search index name with the given type.
|
List<String> |
getIndexNamesForType(String type)
Get the index names with the given type.
|
List<String> |
getInitializedRepositories()
Get the list of repository names that have their index created.
|
long |
getPendingWorkerCount()
Returns the number of indexing worker scheduled waiting to be executed.
|
String |
getRepositoryForIndex(String indexName)
Gets the repository name associated with the index.
|
protected Map<String,String> |
getRepositoryMap() |
List<String> |
getRepositoryNames()
List repository names that have Elasticsearch support.
|
long |
getRunningWorkerCount()
Returns the number of indexing worker that are currently running.
|
protected String[] |
getSearchIndexes(List<String> searchRepositories)
Get the elastic search indexes for searches
|
int |
getTotalCommandProcessed()
Returns the total number of command processed by Elasticsearch for this Nuxeo instance.
|
String |
getWriteIndexName(String searchIndexName)
Returns the index to use for any write operations.
|
protected void |
initializeIndexes() |
protected void |
initIndex(ElasticSearchIndexConfig conf,
boolean dropIfExists) |
protected void |
initIndex(ElasticSearchIndexConfig conf,
boolean dropIfExists,
boolean syncAlias) |
protected void |
initIndex(String indexName,
ElasticSearchIndexConfig conf,
boolean dropIfExists) |
void |
initIndexes(boolean dropIfExists)
Initialize Elasticsearch indexes.
|
protected void |
initSearchAlias(ElasticSearchIndexConfig conf) |
protected void |
initWriteAlias(ElasticSearchIndexConfig conf,
boolean dropIfExists) |
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.
|
boolean |
isReady() |
void |
optimize()
Elasticsearch run
ElasticSearchAdmin.optimizeRepositoryIndex(java.lang.String) on all document indexes, |
void |
optimizeIndex(String indexName)
Elasticsearch optimize operation allows to reduce the number of segments to one, Note that this can potentially
be a very heavy operation.
|
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.
|
protected void |
syncSearchAndWriteAlias(ElasticSearchIndexConfig conf)
Update the search index to point to the write index.
|
void |
syncSearchAndWriteAlias(String searchIndexName)
Make sure that the search alias point to the same index as the write alias.
|
boolean |
useExternalVersion()
When true use an external version for Elasticsearch document, this enable an optimistic concurrency control
ensuring that an older version of a document never overwrites a newer version.
|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
dropAndInitRepositoryIndex
protected static final int TIMEOUT_WAIT_FOR_CLUSTER_SECOND
protected static final int TIMEOUT_DELETE_SECOND
protected final AtomicInteger totalCommandProcessed
protected final Map<String,String> indexNames
protected final Map<String,String> writeIndexNames
protected final Map<String,ElasticSearchIndexConfig> indexConfig
protected final ElasticSearchEmbeddedServerConfig embeddedServerConfig
protected final ElasticSearchClientConfig clientConfig
protected ElasticSearchEmbeddedNode embeddedServer
protected boolean indexInitDone
protected String[] includeSourceFields
protected String[] excludeSourceFields
protected List<String> repositoryInitialized
public ElasticSearchAdminImpl(ElasticSearchEmbeddedServerConfig embeddedServerConfig, ElasticSearchClientConfig clientConfig, Map<String,ElasticSearchIndexConfig> indexConfig)
protected void checkConfig()
protected void connect()
public void disconnect()
protected ESClient createClient(ElasticSearchEmbeddedNode node)
protected void checkClusterHealth(String... indexNames)
protected void initializeIndexes()
public void refreshRepositoryIndex(String repositoryName)
ElasticSearchAdmin
refreshRepositoryIndex
in interface ElasticSearchAdmin
public String getIndexNameForRepository(String repositoryName)
ElasticSearchAdmin
getIndexNameForRepository
in interface ElasticSearchAdmin
public String getRepositoryForIndex(String indexName)
ElasticSearchAdmin
getRepositoryForIndex
in interface ElasticSearchAdmin
public List<String> getIndexNamesForType(String type)
ElasticSearchAdmin
getIndexNamesForType
in interface ElasticSearchAdmin
public String getIndexNameForType(String type)
ElasticSearchAdmin
getIndexNameForType
in interface ElasticSearchAdmin
public String getWriteIndexName(String searchIndexName)
ElasticSearchAdmin
getWriteIndexName
in interface ElasticSearchAdmin
public void syncSearchAndWriteAlias(String searchIndexName)
ElasticSearchAdmin
syncSearchAndWriteAlias
in interface ElasticSearchAdmin
public void flushRepositoryIndex(String repositoryName)
ElasticSearchAdmin
flushRepositoryIndex
in interface ElasticSearchAdmin
public void refresh()
ElasticSearchAdmin
refresh
in interface ElasticSearchAdmin
public void flush()
ElasticSearchAdmin
flush
in interface ElasticSearchAdmin
public void optimizeIndex(String indexName)
ElasticSearchAdmin
optimizeIndex
in interface ElasticSearchAdmin
public void optimizeRepositoryIndex(String repositoryName)
ElasticSearchAdmin
optimizeRepositoryIndex
in interface ElasticSearchAdmin
public void optimize()
ElasticSearchAdmin
ElasticSearchAdmin.optimizeRepositoryIndex(java.lang.String)
on all document indexes,optimize
in interface ElasticSearchAdmin
public ESClient getClient()
ElasticSearchAdmin
Client
that can be used to access Elasticsearch APIgetClient
in interface ElasticSearchAdmin
public void initIndexes(boolean dropIfExists)
ElasticSearchAdmin
initIndexes
in interface ElasticSearchAdmin
dropIfExists
- if {true} remove an existing indexpublic void dropAndInitIndex(String indexName)
ElasticSearchAdmin
dropAndInitIndex
in interface ElasticSearchAdmin
public void dropAndInitRepositoryIndex(String repositoryName, boolean syncAlias)
ElasticSearchAdmin
ElasticSearchAdmin.syncSearchAndWriteAlias(String)
dropAndInitRepositoryIndex
in interface ElasticSearchAdmin
public List<String> getRepositoryNames()
ElasticSearchAdmin
getRepositoryNames
in interface ElasticSearchAdmin
protected void initIndex(ElasticSearchIndexConfig conf, boolean dropIfExists)
protected void initIndex(ElasticSearchIndexConfig conf, boolean dropIfExists, boolean syncAlias)
protected void initWriteAlias(ElasticSearchIndexConfig conf, boolean dropIfExists)
protected void initSearchAlias(ElasticSearchIndexConfig conf)
protected void syncSearchAndWriteAlias(ElasticSearchIndexConfig conf)
protected void initIndex(String indexName, ElasticSearchIndexConfig conf, boolean dropIfExists)
public long getPendingWorkerCount()
ElasticSearchAdmin
getPendingWorkerCount
in interface ElasticSearchAdmin
public long getRunningWorkerCount()
ElasticSearchAdmin
getRunningWorkerCount
in interface ElasticSearchAdmin
public int getTotalCommandProcessed()
ElasticSearchAdmin
getTotalCommandProcessed
in interface ElasticSearchAdmin
public boolean isEmbedded()
ElasticSearchAdmin
isEmbedded
in interface ElasticSearchAdmin
public boolean useExternalVersion()
ElasticSearchAdmin
useExternalVersion
in interface ElasticSearchAdmin
public boolean isIndexingInProgress()
ElasticSearchAdmin
isIndexingInProgress
in interface ElasticSearchAdmin
public com.google.common.util.concurrent.ListenableFuture<Boolean> prepareWaitForIndexing()
ElasticSearchAdmin
Future
that accepts callback on completion when all the indexing worker are done.prepareWaitForIndexing
in interface ElasticSearchAdmin
protected String[] getSearchIndexes(List<String> searchRepositories)
public boolean isReady()
protected String[] getIncludeSourceFields()
protected String[] getExcludeSourceFields()
protected Map<String,String> getRepositoryMap()
public List<String> getInitializedRepositories()
Copyright © 2019 Nuxeo. All rights reserved.