Package com.flowable.indexing

Class ElasticsearchClientImpl

java.lang.Object
com.flowable.indexing.ElasticsearchClientImpl
All Implemented Interfaces:
ElasticsearchClient
public class ElasticsearchClientImpl
extends java.lang.Object
implements ElasticsearchClient

  • Field Summary

    Fields 
    Modifier and Type Field Description
    protected static java.util.Map<java.lang.String,​java.lang.String> DEFAULT_PARAMS  
    protected ElasticsearchCompatibility elasticsearchCompatibility  
    protected static java.lang.String INCLUDE_TYPE_NAME_PARAMETER  
    protected com.fasterxml.jackson.databind.ObjectMapper objectMapper  
    protected org.elasticsearch.client.RestHighLevelClient restClient  

  • Constructor Summary

    Constructors 
    Constructor Description
    ElasticsearchClientImpl​(org.elasticsearch.client.RestHighLevelClient restClient, com.fasterxml.jackson.databind.ObjectMapper objectMapper, ElasticsearchCompatibility elasticsearchCompatibility)  

  • Method Summary

    Modifier and Type Method Description
    protected void addIncludeTypeNameParameterIfNeeded​(org.elasticsearch.client.Request request)  
    protected com.fasterxml.jackson.databind.node.ObjectNode createAliasActionNode​(java.lang.String indexName, java.lang.String aliasName, java.lang.String action, com.fasterxml.jackson.databind.JsonNode filter)  
    void createAliasForIndex​(java.lang.String alias, java.lang.String index)
    Creates a new alias for the given index.
    void createCustomAlias​(java.lang.String alias, java.lang.String indexMapping)  
    com.fasterxml.jackson.databind.JsonNode createIndex​(java.lang.String indexName, java.lang.String alias, java.lang.String indexMapping)
    Creates an index with the given name and creates an alias with the same name at the same time.
    void deleteAliasAndRelatedIndices​(java.lang.String alias)  
    void deleteAliasForIndex​(java.lang.String alias, java.lang.String index)  
    void deleteAllIndicesWithPrefix​(java.lang.String prefix)  
    void deleteByQuery​(java.lang.String index, com.fasterxml.jackson.databind.node.ObjectNode requestNode)  
    void deleteDocument​(java.lang.String alias, java.lang.String id)  
    void deleteIndexIfExists​(java.lang.String index)  
    protected com.fasterxml.jackson.databind.JsonNode getAliasesForIndex​(java.lang.String index)  
    com.fasterxml.jackson.databind.JsonNode getById​(java.lang.String index, java.lang.String id)  
    com.fasterxml.jackson.databind.JsonNode getIndexCurrentMapping​(java.lang.String index)  
    java.lang.String getIndexNameForAlias​(java.lang.String alias)  
    protected com.fasterxml.jackson.databind.JsonNode getJsonNode​(java.lang.String queryEndpoint, org.apache.http.HttpEntity entity)  
    com.fasterxml.jackson.databind.ObjectMapper getObjectMapper()  
    org.elasticsearch.client.RestHighLevelClient getRestHighLevelClient()  
    org.elasticsearch.client.RestClient getRestLowLevelClient()  
    com.fasterxml.jackson.databind.JsonNode getVersionInformation()  
    boolean indexExists​(java.lang.String index)  
    com.fasterxml.jackson.databind.JsonNode query​(java.lang.String index, com.fasterxml.jackson.databind.node.ObjectNode queryBody)  
    com.fasterxml.jackson.databind.JsonNode query​(java.lang.String index, java.lang.String queryBody)  
    protected void refreshAll()  
    void refreshIndex​(java.lang.String index)  
    void setObjectMapper​(com.fasterxml.jackson.databind.ObjectMapper objectMapper)  
    void swapAlias​(java.lang.String alias, java.lang.String oldIndexName, java.lang.String newIndexName)
    Swaps the alias from one index to another index.
    void synchronousIndexDocumentRequest​(java.lang.String index, java.lang.String id, com.fasterxml.jackson.databind.node.ObjectNode objectNode, java.lang.Long version)
    Indexes a document using external versioning through Elasticsearch Index API, overriding the whole document.
    void synchronousUpdateDocumentRequest​(java.lang.String index, java.lang.String id, com.fasterxml.jackson.databind.node.ObjectNode objectNode, com.fasterxml.jackson.databind.node.ObjectNode scriptNode)  
    void synchronousUpsertDocumentRequest​(java.lang.String index, java.lang.String id, com.fasterxml.jackson.databind.node.ObjectNode objectNode)
    Indexes a document using an upsert query
    void updateAliasMapping​(java.lang.String indexName, java.lang.String aliasName, com.fasterxml.jackson.databind.JsonNode indexMapping)  
    void updateByQuery​(java.lang.String index, com.fasterxml.jackson.databind.node.ObjectNode requestNode)  
    void updateIndexMapping​(java.lang.String indexName, com.fasterxml.jackson.databind.JsonNode mappingDelta)  
    void updateIndexMetaData​(java.lang.String index, com.fasterxml.jackson.databind.JsonNode metaData)  

    Methods inherited from class java.lang.Object

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