ElasticsearchRepository

java.lang.Object
- lumis.portal.bigdata.elasticsearch.ElasticsearchRepository

All Implemented Interfaces:

IBigDataIndexer, IBigDataRepository, IBigDataSearcher, IBigDataRepositorySPI
```
public class ElasticsearchRepository
extends Object
implements IBigDataRepositorySPI
```
Big data repository implementation that uses Elasticsearch.

Since:

8.1.0

Version:

$Revision: 23534 $ $Date: 2020-01-14 16:16:30 +0000 (Tue, 14 Jan 2020) $

Field Summary

Fields
Modifier and Type	Field and Description
`protected BulkProcessor`	`bulkProcessor` The `BulkProcessor` instance shared with `IBatchIndexer` generated by this repository.
`protected org.elasticsearch.client.Client`	`client`
`static List<Locale>`	`NATIVE_TEMPLATES_SYNONYMS_LOCALES`
`protected ElasticsearchRepository`	`repository`
`static String`	`UNIQUE_DOC_TYPE_NAME`

Constructor Summary

Constructors
Constructor and Description

ElasticsearchRepository()

Constructors
Constructor and Description
`ElasticsearchRepository()`

Method Summary

All Methods Instance Methods Concrete Methods Deprecated Methods
Modifier and Type	Method and Description
`void`	`addDocument(Document document)` Adds a document to the index.
`void`	`addDocumentToIndexQueue(Document document)` Adds a document that may be delayed until it is indexed.
`void`	`addIndex(Locale locale)` Adds the indices relative to the given locale in Elasticsearch.
`void`	`addOrUpdateDocument(Document document)` Adds or updates a document on the index.
`void`	`addOrUpdateDocumentType(DocumentType documentType)` Deprecated.
`void`	`addOrUpdateDocumentType(DocumentType documentType, boolean force)` Adds or updates a document type into managed indices. If the managed indices couldn't be updated in underlying big data repository: If `force` parameter is `true`, they will be recreated, causing data loss. Else, an `IllegalArgumentException` will be raised.
`void`	`deleteDocument(DocumentType documentType, Locale locale, String documentId)` Deletes a document from the index with the given specifications.
`void`	`deleteDocumentsByFieldValue(String fieldId, Collection<?> values)` Deletes documents that are matched by one of the given values in the field of given field identifier.
`void`	`deleteDocumentsByFieldValue(String fieldId, Object... values)` Deletes documents that are matched by one of the given values in the field of given field identifier.
`void`	`deleteDocumentsByQuery(SearchQuery searchQuery)` Deletes documents that are matched by the given search query. The search query's `sorts`, `initial hit` and `maximum hit count` will be ignored.
`void`	`deleteDocumentType(String documentTypeId)` Deletes a given document type from managed indices.
`void`	`deleteIndex(Locale locale)` Deletes the indices related to the given locale.
`void`	`deleteIndicesTemplates()` Delete the all index templates.
`void`	`destroy()` Destroy this repository and performs any required resource freeing.
`protected void`	`executeAsync(org.elasticsearch.action.ActionRequest request)` Sends a request to Elasticsearch to be executed asynchronously.
`protected void`	`executeAsync(org.elasticsearch.action.ActionRequest request, boolean doFlush)` Sends a request to Elasticsearch to be executed asynchronously.
`protected <T extends org.elasticsearch.action.ActionResponse> T`	`executeSync(org.elasticsearch.action.ActionRequestBuilder<?,T> request)` Executes a request to Elasticsearch synchronously and returns the response.
`protected <T extends org.elasticsearch.action.ActionResponse> T`	`executeSync(org.elasticsearch.action.ActionRequestBuilder<?,T> request, boolean remapException)` Executes a request to Elasticsearch synchronously and returns the response.
`Map<String,? extends DocumentType>`	`getAllDocumentTypes()` Returns all document types, indexed by document type identifier.
`String[]`	`getAllIndicesNames(DocumentType type)` Return all portal indices names for a type - for each locale - include null - generate a index name.
`List<String>`	`getAutoCompleteSuggestions(SearchQuery searchQuery, AutoCompleteSuggestionConfig autoCompleteSuggestion)` Returns a list of auto complete suggestions for the given auto complete suggestion configuration and the search query.
`protected org.elasticsearch.action.search.SearchRequestBuilder`	`getBaseQuery(SearchQuery searchQuery)` Returns a search request builder based on the given `SearchQuery`.
`BulkProcessor`	`getBulkProcessor()` Returns an internal bulk processor used by this repository.
`org.elasticsearch.client.Client`	`getDelegate()` Returns the underlying Elasticsearch client of this repository.
`DocumentType`	`getDocumentType(String documentTypeId)` Returns the document type of the given identifier.
`DocumentType`	`getDocumentTypeByIndex(String index)` Return the `DocumentType` for index name.
`DocumentTypeField`	`getDocumentTypeField(String documentTypeFieldFullId)` Return the document type field of the field that has the given identifier.
`org.elasticsearch.action.search.SearchRequestBuilder`	`getElasticsearchQuery(SearchQuery searchQuery)` Returns the Elasticsearch search query for the given `SearchQuery`.
`String`	`getElasticsearchType(DocumentType documentType)` Return the doctype that is save in elasticsearch mapping.
`String`	`getIndexTemplateSettings(Locale locale)` Returns the index template settings for the given locale.
`org.elasticsearch.index.query.QueryBuilder`	`getQueryBuilder(SearchQuery searchQuery)` Generates a Elasticsearch's `QueryBuilder` initialized according to a LumisXP's `SearchQuery`.
`String`	`getRetiredAliasName()` Returns the alias used for LumisXP indices that were used in previous versions but are no longer used in current version.
`String`	`getSearchAliasName()` Returns the alias used for searching in LumisXP indices.
`Map<Locale,IFile>`	`getSynonymsFiles()` Return a map with all files that the portal need to create based the Locales of synonyms and Locales of portal.
`void`	`init(String repositoryId)` Initializes this repository using the given `node` as configuration.
`protected void`	`logRequest(Object request)` Logs at debug level a request that will be sent to Elasticsearch.
`Document`	`readDocument(DocumentType documentType, Locale locale, String documentId)` Reads a document from the repository with the given specifications.
`void`	`refreshIndices(Collection<String> documentTypeIds, Locale... locales)` Refresh the indices of the given document type.
`void`	`refreshIndices(DocumentType documentType, Locale... locales)` Refresh the indices of the given document type.
`void`	`refreshIndices(String documentTypeId, Locale... locales)` Refresh the indices of the given document type.
`void`	`reloadSynonyms()` Reloads the synonyms in this repository.
`ISearchResults`	`search(SearchQuery searchQuery)` Runs the given `search query` and returns the `search results`.
`<T> List<T>`	`searchUsingScroll(org.elasticsearch.action.search.SearchRequestBuilder query, int startAt, int maxResults, java.util.function.Function<org.elasticsearch.action.search.SearchResponse,List<T>> collector)` Performs the searching using scroll and collect data from all ranges.
`IBatchIndexer`	`startBatch()` Returns an indexer to perform bulk actions. The caller must assure `IBatchIndexer.close()` is called after the desired bulk operations were performed.
`void`	`updateDocumentsByQuerySync(SearchQuery searchQuery, Map<String,Object> fieldValues)` Updates documents that matches a `SearchQuery` updating their field values according to the `fieldValues` map.
`void`	`validate(SearchQuery searchQuery)` Checks is the given `search query` is syntactically correct.

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface lumis.portal.bigdata.IBigDataIndexer
addDocument, addOrUpdateDocument, deleteDocument, deleteDocumentsByFieldValue, deleteDocumentsByFieldValue, updateDocumentsByQuerySync

- Field Detail
  - UNIQUE_DOC_TYPE_NAME
```
public static final String UNIQUE_DOC_TYPE_NAME
```
    See Also:
    
    Constant Field Values
  - NATIVE_TEMPLATES_SYNONYMS_LOCALES
```
public static final List<Locale> NATIVE_TEMPLATES_SYNONYMS_LOCALES
```
  - client
```
protected org.elasticsearch.client.Client client
```
  - bulkProcessor
```
protected BulkProcessor bulkProcessor
```
    The BulkProcessor instance shared with IBatchIndexer generated by this repository.
    
    Since:
    
    8.1.0
    
    See Also:
    
    startBatch()
  - repository
```
protected ElasticsearchRepository repository
```
- Constructor Detail
  - ElasticsearchRepository
```
public ElasticsearchRepository()
```
- Method Detail
  - init
```
public void init(String repositoryId)
```
    Description copied from interface: IBigDataRepositorySPI
    
    Initializes this repository using the given node as configuration.
    
    Specified by:
    
    init in interface IBigDataRepositorySPI
    
    Parameters:
    
    repositoryId - the repository identifier.
  - deleteIndicesTemplates
```
public void deleteIndicesTemplates()
```
    Delete the all index templates.
    
    Since:
    
    11.1.0
  - getSearchAliasName
```
public String getSearchAliasName()
```
    Returns the alias used for searching in LumisXP indices.
    
    Returns:
    
    the alias.
    
    Since:
    
    8.2.1
  - getRetiredAliasName
```
public String getRetiredAliasName()
```
    Returns the alias used for LumisXP indices that were used in previous versions but are no longer used in current version.
    This method is intended for use by special upgrade tasks so they can find the indices with previous versions data so they can convert them to current format.
    
    Returns:
    
    the alias.
    
    Since:
    
    11.0.0
  - addIndex
```
public void addIndex(Locale locale)
```
    Adds the indices relative to the given locale in Elasticsearch.
    
    Parameters:
    
    locale - the locale the indices to be created refers to.
    
    Since:
    
    8.1.0
  - deleteIndex
```
public void deleteIndex(Locale locale)
```
    Deletes the indices related to the given locale.
    
    Parameters:
    
    locale - the locale.
    
    Since:
    
    8.1.0
  - getIndexTemplateSettings
```
public String getIndexTemplateSettings(Locale locale)
```
    Returns the index template settings for the given locale.
    
    Parameters:
    
    locale - the locale or null for locale agnostic settings.
    
    Returns:
    
    the index template settings for the given locale.
    
    Since:
    
    8.2.1
  - destroy
```
public void destroy()
```
    Description copied from interface: IBigDataRepositorySPI
    
    Destroy this repository and performs any required resource freeing.
    
    Specified by:
    
    destroy in interface IBigDataRepositorySPI
  - addOrUpdateDocumentType
```
@Deprecated
public void addOrUpdateDocumentType(DocumentType documentType)
```
    Deprecated.
    
    Description copied from interface: IBigDataRepository
    
    Adds or updates a document type into managed indices.
    If the managed indices couldn't be updated in underlying big data repository, they will be recreated, causing data loss.
    
    Specified by:
    
    addOrUpdateDocumentType in interface IBigDataRepository
    
    Parameters:
    
    documentType - the document type to be added.
    
    See Also:
    
    DocumentTypes
  - addOrUpdateDocumentType
```
public void addOrUpdateDocumentType(DocumentType documentType,
                                    boolean force)
```
    Description copied from interface: IBigDataRepository
    Adds or updates a document type into managed indices.
    If the managed indices couldn't be updated in underlying big data repository:
    - If force parameter is true, they will be recreated, causing data loss.
    - Else, an IllegalArgumentException will be raised.
    Specified by:
    
    addOrUpdateDocumentType in interface IBigDataRepository
    
    Parameters:
    
    documentType - the document type to be added.
    
    force - indicates whether the update should be forced.
    
    See Also:
    
    DocumentTypes
  - getAllIndicesNames
```
public String[] getAllIndicesNames(DocumentType type)
```
    Return all portal indices names for a type - for each locale - include null - generate a index name.
    
    Parameters:
    
    typeName - the type.
    
    Returns:
    
    all with indexed names.
    
    Since:
    
    11.1.0
  - deleteDocumentType
```
public void deleteDocumentType(String documentTypeId)
                        throws PortalObjectNotFoundException
```
    Description copied from interface: IBigDataRepository
    
    Deletes a given document type from managed indices.
    
    Specified by:
    
    deleteDocumentType in interface IBigDataRepository
    
    Parameters:
    
    documentTypeId - the document type identifier to be deleted.
    
    Throws:
    
    PortalObjectNotFoundException - if the document type with the given identifier couldn't be found.
  - getDocumentType
```
public DocumentType getDocumentType(String documentTypeId)
                             throws PortalObjectNotFoundException
```
    Description copied from interface: IBigDataRepository
    
    Returns the document type of the given identifier.
    
    Specified by:
    
    getDocumentType in interface IBigDataRepository
    
    Parameters:
    
    documentTypeId - the document type identifier.
    
    Returns:
    
    the document type of the given identifier.
    
    Throws:
    
    PortalObjectNotFoundException - if the desired type does not exist.
  - getDocumentTypeByIndex
```
public DocumentType getDocumentTypeByIndex(String index)
                                    throws PortalObjectNotFoundException
```
    Return the DocumentType for index name.
    
    Parameters:
    
    index - the index name.
    
    Returns:
    
    the index DocumentType
    
    Throws:
    
    PortalObjectNotFoundException
    
    Since:
    
    11.1.0
  - getDocumentTypeField
```
public DocumentTypeField getDocumentTypeField(String documentTypeFieldFullId)
                                       throws PortalObjectNotFoundException
```
    Description copied from interface: IBigDataRepository
    
    Return the document type field of the field that has the given identifier.
    
    Specified by:
    
    getDocumentTypeField in interface IBigDataRepository
    
    Parameters:
    
    documentTypeFieldFullId - the (full) identifier of the document type field.
    
    Returns:
    
    the document type field of the field that has the given identifier.
    
    Throws:
    
    PortalObjectNotFoundException - if the desired field does not exist.
  - getAllDocumentTypes
```
public Map<String,? extends DocumentType> getAllDocumentTypes()
```
    Returns all document types, indexed by document type identifier.
    
    Returns:
    
    all document types, indexed by document type identifier.
    
    Since:
    
    8.1.0
  - readDocument
```
public Document readDocument(DocumentType documentType,
                             Locale locale,
                             String documentId)
                      throws PortalObjectNotFoundException
```
    Description copied from interface: IBigDataRepository
    
    Reads a document from the repository with the given specifications.
    
    Specified by:
    
    readDocument in interface IBigDataRepository
    
    Parameters:
    
    documentType - the document's type.
    
    locale - the document's locale as set in its standard locale field. Must be null if the document does not have a locale specified.
    
    documentId - the document's identifier.
    
    Returns:
    
    the document.
    
    Throws:
    
    PortalObjectNotFoundException - if no matching document was found.
  - startBatch
```
public IBatchIndexer startBatch()
```
    Description copied from interface: IBigDataRepository
    
    Returns an indexer to perform bulk actions.
    The caller must assure IBatchIndexer.close() is called after the desired bulk operations were performed.
    Example of usage:
    
    IBatchIndexer batchIndexer = myBigDataRepository.startBatch(); try { // batch operations here } finally { batchIndexer.close(); }
    Or using try-with-resources:
    try(IBatchIndexer batchIndexer = myBigDataRepository.startBatch()) { // batch operations here }
    
    Specified by:
    
    startBatch in interface IBigDataRepository
    
    Returns:
    
    an indexer to perform bulk actions.
  - deleteDocumentsByQuery
```
public void deleteDocumentsByQuery(SearchQuery searchQuery)
```
    Description copied from interface: IBigDataIndexer
    
    Deletes documents that are matched by the given search query.
    The search query's sorts, initial hit and maximum hit count will be ignored.
    
    Specified by:
    
    deleteDocumentsByQuery in interface IBigDataIndexer
    
    Parameters:
    
    searchQuery - the search query.
  - search
```
public ISearchResults search(SearchQuery searchQuery)
```
    Description copied from interface: IBigDataSearcher
    
    Runs the given search query and returns the search results.
    
    Specified by:
    
    search in interface IBigDataSearcher
    
    Parameters:
    
    searchQuery - the query to run.
    
    Returns:
    
    the search results.
  - getElasticsearchQuery
```
public org.elasticsearch.action.search.SearchRequestBuilder getElasticsearchQuery(SearchQuery searchQuery)
```
    Returns the Elasticsearch search query for the given SearchQuery.
    
    Parameters:
    
    searchQuery - the search query.
    
    Returns:
    
    the Elasticsearch search query for the given SearchQuery.
  - searchUsingScroll
```
public <T> List<T> searchUsingScroll(org.elasticsearch.action.search.SearchRequestBuilder query,
                                     int startAt,
                                     int maxResults,
                                     java.util.function.Function<org.elasticsearch.action.search.SearchResponse,List<T>> collector)
```
    Performs the searching using scroll and collect data from all ranges.
    
    Parameters:
    
    query - the query.
    
    startAt - the start at position (1-based).
    
    maxResults - maximum results of query.
    
    collector - the function interface that will collect from response the required data.
    
    Returns:
    
    the required data.
    
    Since:
    
    11.2.0
  - getAutoCompleteSuggestions
```
public List<String> getAutoCompleteSuggestions(SearchQuery searchQuery,
                                               AutoCompleteSuggestionConfig autoCompleteSuggestion)
```
    Description copied from interface: IBigDataSearcher
    
    Returns a list of auto complete suggestions for the given auto complete suggestion configuration and the search query.
    
    Specified by:
    
    getAutoCompleteSuggestions in interface IBigDataSearcher
    
    Parameters:
    
    searchQuery - the search query the auto complete request will be based on.
    
    autoCompleteSuggestion - the auto complete suggestion request.
    
    Returns:
    
    a list of auto complete suggestions for the given auto complete suggestion request.
  - validate
```
public void validate(SearchQuery searchQuery)
              throws PortalException
```
    Description copied from interface: IBigDataSearcher
    
    Checks is the given search query is syntactically correct.
    
    Specified by:
    
    validate in interface IBigDataSearcher
    
    Parameters:
    
    searchQuery - the search query to be validated
    
    Throws:
    
    PortalException - if there is a syntax error in query.
  - getDelegate
```
public org.elasticsearch.client.Client getDelegate()
```
    Returns the underlying Elasticsearch client of this repository.
    
    Specified by:
    
    getDelegate in interface IBigDataRepository
    
    Returns:
    
    the underlying Elasticsearch client of this repository.
  - getBulkProcessor
```
public BulkProcessor getBulkProcessor()
```
    Returns an internal bulk processor used by this repository.
    
    Returns:
    
    bulk processor.
    
    Since:
    
    11.0.0
  - reloadSynonyms
```
public void reloadSynonyms()
                    throws AccessDeniedException,
                           PortalException
```
    Description copied from interface: IBigDataRepositorySPI
    
    Reloads the synonyms in this repository.
    
    Specified by:
    
    reloadSynonyms in interface IBigDataRepositorySPI
    
    Throws:
    
    AccessDeniedException - if user doesn't have the appropriate permission.
    
    PortalException - if some error occur.
  - getSynonymsFiles
```
public Map<Locale,IFile> getSynonymsFiles()
```
    Description copied from interface: IBigDataRepositorySPI
    
    Return a map with all files that the portal need to create based the Locales of synonyms and Locales of portal.
    
    Specified by:
    
    getSynonymsFiles in interface IBigDataRepositorySPI
    
    Returns:
    
    a map that key is Locale, and, value is your file.
  - getElasticsearchType
```
public String getElasticsearchType(DocumentType documentType)
```
    Return the doctype that is save in elasticsearch mapping.
    
    Parameters:
    
    documentType - the documentType.
    
    Returns:
    
    the elasticsearch type.
    
    Since:
    
    11.1.0
  - refreshIndices
```
public void refreshIndices(DocumentType documentType,
                           Locale... locales)
```
    Refresh the indices of the given document type. If no locale is passed, all indices of the given document type will be refreshed.
    
    Parameters:
    
    documentType - the document type.
    
    locales - the locales.
    
    Since:
    
    12.0.0
  - refreshIndices
```
public void refreshIndices(String documentTypeId,
                           Locale... locales)
```
    Refresh the indices of the given document type. If no locale is passed, all indices of the given document type will be refreshed.
    
    Parameters:
    
    documentType - the document type.
    
    locales - the locales.
    
    Since:
    
    12.0.0
  - refreshIndices
```
public void refreshIndices(Collection<String> documentTypeIds,
                           Locale... locales)
```
    Refresh the indices of the given document type. If no locale is passed, all indices of the given document type will be refreshed.
    
    Parameters:
    
    documentTypeIds - the document type identifiers.
    
    locales - the locales.
    
    Since:
    
    12.2.0
  - addDocument
```
public void addDocument(Document document)
```
    Description copied from interface: IBigDataIndexer
    
    Adds a document to the index. If in the index already exists a document with the same document type, identifier and locale then this operation will fail (probably without throwing any exception, since the fail may occur in background as this method may be asynchronous).
    
    Specified by:
    
    addDocument in interface IBigDataIndexer
    
    Parameters:
    
    document - the document to be added.
    
    See Also:
    
    IBigDataIndexer.addOrUpdateDocument(Document)
  - addDocumentToIndexQueue
```
public void addDocumentToIndexQueue(Document document)
```
    Adds a document that may be delayed until it is indexed.
    
    Parameters:
    
    document - the document.
    
    Since:
    
    11.0.0
  - addOrUpdateDocument
```
public void addOrUpdateDocument(Document document)
```
    Description copied from interface: IBigDataIndexer
    
    Adds or updates a document on the index. If in the index already exists a document with the same document type, identifier and locale then the document on the index will be replaced by the given document; otherwise the given document will be added to the index.
    
    Specified by:
    
    addOrUpdateDocument in interface IBigDataIndexer
    
    Parameters:
    
    document - the document to be added.
    
    See Also:
    
    IBigDataIndexer.addDocument(Document)
  - deleteDocument
```
public void deleteDocument(DocumentType documentType,
                           Locale locale,
                           String documentId)
```
    Description copied from interface: IBigDataIndexer
    
    Deletes a document from the index with the given specifications. If no such document exists, this method does nothing.
    
    Specified by:
    
    deleteDocument in interface IBigDataIndexer
    
    Parameters:
    
    documentType - the document's type.
    
    locale - the document's locale as set in its standard locale field. Must be null if the document does not have a locale specified.
    
    documentId - the document's identifier.
  - deleteDocumentsByFieldValue
```
public void deleteDocumentsByFieldValue(String fieldId,
                                        Object... values)
```
    Description copied from interface: IBigDataIndexer
    
    Deletes documents that are matched by one of the given values in the field of given field identifier.
    
    Specified by:
    
    deleteDocumentsByFieldValue in interface IBigDataIndexer
    
    Parameters:
    
    fieldId - the field identifier.
    
    values - the values.
  - deleteDocumentsByFieldValue
```
public void deleteDocumentsByFieldValue(String fieldId,
                                        Collection<?> values)
```
    Description copied from interface: IBigDataIndexer
    
    Deletes documents that are matched by one of the given values in the field of given field identifier.
    
    Specified by:
    
    deleteDocumentsByFieldValue in interface IBigDataIndexer
    
    Parameters:
    
    fieldId - the field identifier.
    
    values - the values.
  - updateDocumentsByQuerySync
```
public void updateDocumentsByQuerySync(SearchQuery searchQuery,
                                       Map<String,Object> fieldValues)
```
    Description copied from interface: IBigDataIndexer
    
    Updates documents that matches a SearchQuery updating their field values according to the fieldValues map.
    This operation is synchronous in relation to the completion of the update execution. Searches performed after this method returns may not reflect the update, since internal optimizations and behavior of the underlying big data storage may demand some time for the update to be visible to searches.
    
    Specified by:
    
    updateDocumentsByQuerySync in interface IBigDataIndexer
    
    Parameters:
    
    searchQuery - the search query.
    
    fieldValues - a map where the key is a field's full identifier and the value is the value to be set on the corresponding field. The value must be of a type compatible with the field type. If the value is null,
  - getBaseQuery
```
protected org.elasticsearch.action.search.SearchRequestBuilder getBaseQuery(SearchQuery searchQuery)
```
    Returns a search request builder based on the given SearchQuery. Does not add sort, aggregations, start at and max rows.
    
    Parameters:
    
    searchQuery - the search query.
    
    Returns:
    
    a search request builder based on the given SearchQuery.
    
    Since:
    
    8.1.0
  - getQueryBuilder
```
public org.elasticsearch.index.query.QueryBuilder getQueryBuilder(SearchQuery searchQuery)
```
    Generates a Elasticsearch's QueryBuilder initialized according to a LumisXP's SearchQuery.
    
    Parameters:
    
    searchQuery - the LumisXP's search query.
    
    Returns:
    
    the Elasticsearch's query builder.
    
    Since:
    
    11.0.0
  - executeSync
```
protected <T extends org.elasticsearch.action.ActionResponse> T executeSync(org.elasticsearch.action.ActionRequestBuilder<?,T> request)
```
    Executes a request to Elasticsearch synchronously and returns the response.
    
    Since:
    
    8.1.0
  - executeSync
```
protected <T extends org.elasticsearch.action.ActionResponse> T executeSync(org.elasticsearch.action.ActionRequestBuilder<?,T> request,
                                                                            boolean remapException)
```
    Executes a request to Elasticsearch synchronously and returns the response.
    
    Since:
    
    8.1.0
  - executeAsync
```
protected void executeAsync(org.elasticsearch.action.ActionRequest request)
```
    Sends a request to Elasticsearch to be executed asynchronously.
    
    Since:
    
    8.1.0
  - executeAsync
```
protected void executeAsync(org.elasticsearch.action.ActionRequest request,
                            boolean doFlush)
```
    Sends a request to Elasticsearch to be executed asynchronously.
    
    Since:
    
    11.0.0
  - logRequest
```
protected void logRequest(Object request)
```
    Logs at debug level a request that will be sent to Elasticsearch.
    
    Parameters:
    
    request - the request object.
    
    Since:
    
    8.1.0

Class ElasticsearchRepository

Field Summary

Constructor Summary

Method Summary

Methods inherited from class java.lang.Object

Methods inherited from interface lumis.portal.bigdata.IBigDataIndexer

Field Detail

UNIQUE_DOC_TYPE_NAME

NATIVE_TEMPLATES_SYNONYMS_LOCALES

client

bulkProcessor

repository

Constructor Detail

ElasticsearchRepository

Method Detail

init

deleteIndicesTemplates

getSearchAliasName

getRetiredAliasName

addIndex

deleteIndex

getIndexTemplateSettings

destroy

addOrUpdateDocumentType

addOrUpdateDocumentType

getAllIndicesNames

deleteDocumentType

getDocumentType

getDocumentTypeByIndex

getDocumentTypeField

getAllDocumentTypes

readDocument

startBatch

deleteDocumentsByQuery

search

getElasticsearchQuery

searchUsingScroll

getAutoCompleteSuggestions

validate

getDelegate

getBulkProcessor

reloadSynonyms

getSynonymsFiles

getElasticsearchType

refreshIndices

refreshIndices

refreshIndices

addDocument

addDocumentToIndexQueue

addOrUpdateDocument

deleteDocument

deleteDocumentsByFieldValue

deleteDocumentsByFieldValue

updateDocumentsByQuerySync

getBaseQuery

getQueryBuilder

executeSync

executeSync

executeAsync

executeAsync

logRequest