com.flowable.indexing

Class ElasticsearchClientImpl

java.lang.Object

com.flowable.indexing.ElasticsearchClientImpl

All Implemented Interfaces:

ElasticsearchClient

public class ElasticsearchClientImpl
extends Object
implements ElasticsearchClient

Field Summary

Fields

Modifier and Type	Field and Description
protected ElasticsearchCompatibility	elasticsearchCompatibility
protected static String	INCLUDE_TYPE_NAME_PARAMETER
protected com.fasterxml.jackson.databind.ObjectMapper	objectMapper
protected org.elasticsearch.client.RestHighLevelClient	restClient

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
protected void	addIncludeTypeNameParameterIfNeeded(org.elasticsearch.client.Request request)
protected FlowableException	asFlowableException(org.elasticsearch.client.ResponseException responseException, String fallbackMessage)
protected com.fasterxml.jackson.databind.node.ObjectNode	createAliasActionNode(String indexName, String aliasName, String action, com.fasterxml.jackson.databind.JsonNode filter)
void	createAliasForIndex(String alias, String index) Creates a new alias for the given index.
void	createCustomAlias(String alias, String indexMapping)
com.fasterxml.jackson.databind.JsonNode	createIndex(String indexName, String alias, String indexMapping) Creates an index with the given name and creates an alias with the same name at the same time.
void	deleteAliasAndRelatedIndices(String alias)
void	deleteAliasForIndex(String alias, String index)
void	deleteAllIndicesWithPrefix(String prefix)
void	deleteByQuery(String index, com.fasterxml.jackson.databind.node.ObjectNode requestNode)
void	deleteDocument(String alias, String id)
void	deleteIndexIfExists(String index)
protected com.fasterxml.jackson.databind.JsonNode	getAliasesForIndex(String index)
com.fasterxml.jackson.databind.JsonNode	getById(String index, String id)
com.fasterxml.jackson.databind.JsonNode	getIndexCurrentMapping(String index)
String	getIndexNameForAlias(String alias)
protected com.fasterxml.jackson.databind.JsonNode	getJsonNode(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(String index)
com.fasterxml.jackson.databind.JsonNode	query(String index, com.fasterxml.jackson.databind.node.ObjectNode queryBody)
com.fasterxml.jackson.databind.JsonNode	query(String index, String queryBody)
protected void	refreshAll()
void	refreshIndex(String index)
protected String	responseMessage(org.elasticsearch.client.Response response, String fallbackMessage)
void	setObjectMapper(com.fasterxml.jackson.databind.ObjectMapper objectMapper)
void	swapAlias(String alias, String oldIndexName, String newIndexName) Swaps the alias from one index to another index.
void	synchronousIndexDocumentRequest(String index, String id, com.fasterxml.jackson.databind.node.ObjectNode objectNode, Long version) Indexes a document using external versioning through Elasticsearch Index API, overriding the whole document.
void	synchronousUpdateDocumentRequest(String index, String id, com.fasterxml.jackson.databind.node.ObjectNode objectNode, com.fasterxml.jackson.databind.node.ObjectNode scriptNode)
void	synchronousUpsertDocumentRequest(String index, String id, com.fasterxml.jackson.databind.node.ObjectNode objectNode) Indexes a document using an upsert query
void	updateAliasMapping(String indexName, String aliasName, com.fasterxml.jackson.databind.JsonNode indexMapping)
void	updateByQuery(String index, com.fasterxml.jackson.databind.node.ObjectNode requestNode)
void	updateIndexMapping(String indexName, com.fasterxml.jackson.databind.JsonNode mappingDelta)
void	updateIndexMetaData(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

Field Detail

INCLUDE_TYPE_NAME_PARAMETER

protected static final String INCLUDE_TYPE_NAME_PARAMETER

See Also:

Constant Field Values

restClient

protected org.elasticsearch.client.RestHighLevelClient restClient

objectMapper

protected com.fasterxml.jackson.databind.ObjectMapper objectMapper

elasticsearchCompatibility

protected ElasticsearchCompatibility elasticsearchCompatibility

Constructor Detail

ElasticsearchClientImpl

public ElasticsearchClientImpl(org.elasticsearch.client.RestHighLevelClient restClient,
                               com.fasterxml.jackson.databind.ObjectMapper objectMapper,
                               ElasticsearchCompatibility elasticsearchCompatibility)

Method Detail

getIndexCurrentMapping

public com.fasterxml.jackson.databind.JsonNode getIndexCurrentMapping(String index)

Specified by:

getIndexCurrentMapping in interface ElasticsearchClient

updateIndexMetaData

public void updateIndexMetaData(String index,
                                com.fasterxml.jackson.databind.JsonNode metaData)

Specified by:

updateIndexMetaData in interface ElasticsearchClient

getVersionInformation

public com.fasterxml.jackson.databind.JsonNode getVersionInformation()

Specified by:

getVersionInformation in interface ElasticsearchClient

createCustomAlias

public void createCustomAlias(String alias,
                              String indexMapping)

Specified by:

createCustomAlias in interface ElasticsearchClient

createIndex

public com.fasterxml.jackson.databind.JsonNode createIndex(String indexName,
                                                           String alias,
                                                           String indexMapping)

Description copied from interface: ElasticsearchClient

Creates an index with the given name and creates an alias with the same name at the same time.

Specified by:

createIndex in interface ElasticsearchClient

Parameters:

indexName - The name of the index.

alias - The alias name for the index. If alias is null, NO alias will be created, but the index still will be created.

indexMapping - The full ES mapping json that will be created.

createAliasForIndex

public void createAliasForIndex(String alias,
                                String index)

Description copied from interface: ElasticsearchClient

Creates a new alias for the given index.

Specified by:

createAliasForIndex in interface ElasticsearchClient

getAliasesForIndex

protected com.fasterxml.jackson.databind.JsonNode getAliasesForIndex(String index)

swapAlias

public void swapAlias(String alias,
                      String oldIndexName,
                      String newIndexName)

Description copied from interface: ElasticsearchClient

Swaps the alias from one index to another index.

Specified by:

swapAlias in interface ElasticsearchClient

synchronousUpsertDocumentRequest

public void synchronousUpsertDocumentRequest(String index,
                                             String id,
                                             com.fasterxml.jackson.databind.node.ObjectNode objectNode)

Description copied from interface: ElasticsearchClient

Indexes a document using an upsert query

Specified by:

synchronousUpsertDocumentRequest in interface ElasticsearchClient

synchronousIndexDocumentRequest

public void synchronousIndexDocumentRequest(String index,
                                            String id,
                                            com.fasterxml.jackson.databind.node.ObjectNode objectNode,
                                            Long version)

Description copied from interface: ElasticsearchClient

Indexes a document using external versioning through Elasticsearch Index API, overriding the whole document. Update API is not available for external versioning.

Specified by:

synchronousIndexDocumentRequest in interface ElasticsearchClient

synchronousUpdateDocumentRequest

public void synchronousUpdateDocumentRequest(String index,
                                             String id,
                                             com.fasterxml.jackson.databind.node.ObjectNode objectNode,
                                             com.fasterxml.jackson.databind.node.ObjectNode scriptNode)

Specified by:

synchronousUpdateDocumentRequest in interface ElasticsearchClient

updateByQuery

public void updateByQuery(String index,
                          com.fasterxml.jackson.databind.node.ObjectNode requestNode)

Specified by:

updateByQuery in interface ElasticsearchClient

deleteDocument

public void deleteDocument(String alias,
                           String id)

Specified by:

deleteDocument in interface ElasticsearchClient

deleteByQuery

public void deleteByQuery(String index,
                          com.fasterxml.jackson.databind.node.ObjectNode requestNode)

Specified by:

deleteByQuery in interface ElasticsearchClient

query

public com.fasterxml.jackson.databind.JsonNode query(String index,
                                                     com.fasterxml.jackson.databind.node.ObjectNode queryBody)

Specified by:

query in interface ElasticsearchClient

getById

public com.fasterxml.jackson.databind.JsonNode getById(String index,
                                                       String id)

Specified by:

getById in interface ElasticsearchClient

query

public com.fasterxml.jackson.databind.JsonNode query(String index,
                                                     String queryBody)

Specified by:

query in interface ElasticsearchClient

getJsonNode

protected com.fasterxml.jackson.databind.JsonNode getJsonNode(String queryEndpoint,
                                                              org.apache.http.HttpEntity entity)

deleteIndexIfExists

public void deleteIndexIfExists(String index)

Specified by:

deleteIndexIfExists in interface ElasticsearchClient

deleteAllIndicesWithPrefix

public void deleteAllIndicesWithPrefix(String prefix)

Specified by:

deleteAllIndicesWithPrefix in interface ElasticsearchClient

indexExists

public boolean indexExists(String index)

Specified by:

indexExists in interface ElasticsearchClient

createAliasActionNode

protected com.fasterxml.jackson.databind.node.ObjectNode createAliasActionNode(String indexName,
                                                                               String aliasName,
                                                                               String action,
                                                                               com.fasterxml.jackson.databind.JsonNode filter)

updateAliasMapping

public void updateAliasMapping(String indexName,
                               String aliasName,
                               com.fasterxml.jackson.databind.JsonNode indexMapping)

Specified by:

updateAliasMapping in interface ElasticsearchClient

updateIndexMapping

public void updateIndexMapping(String indexName,
                               com.fasterxml.jackson.databind.JsonNode mappingDelta)

Specified by:

updateIndexMapping in interface ElasticsearchClient

deleteAliasAndRelatedIndices

public void deleteAliasAndRelatedIndices(String alias)

Specified by:

deleteAliasAndRelatedIndices in interface ElasticsearchClient

refreshAll

protected void refreshAll()

deleteAliasForIndex

public void deleteAliasForIndex(String alias,
                                String index)

Specified by:

deleteAliasForIndex in interface ElasticsearchClient

refreshIndex

public void refreshIndex(String index)

Specified by:

refreshIndex in interface ElasticsearchClient

getIndexNameForAlias

public String getIndexNameForAlias(String alias)

Specified by:

getIndexNameForAlias in interface ElasticsearchClient

addIncludeTypeNameParameterIfNeeded

protected void addIncludeTypeNameParameterIfNeeded(org.elasticsearch.client.Request request)

getRestLowLevelClient

public org.elasticsearch.client.RestClient getRestLowLevelClient()

Specified by:

getRestLowLevelClient in interface ElasticsearchClient

getRestHighLevelClient

public org.elasticsearch.client.RestHighLevelClient getRestHighLevelClient()

Specified by:

getRestHighLevelClient in interface ElasticsearchClient

getObjectMapper

public com.fasterxml.jackson.databind.ObjectMapper getObjectMapper()

setObjectMapper

public void setObjectMapper(com.fasterxml.jackson.databind.ObjectMapper objectMapper)

asFlowableException

protected FlowableException asFlowableException(org.elasticsearch.client.ResponseException responseException,
                                                String fallbackMessage)

responseMessage

protected String responseMessage(org.elasticsearch.client.Response response,
                                 String fallbackMessage)