Package com.flowable.indexing
Interface ElasticsearchClient
-
- All Known Implementing Classes:
ElasticsearchClientImpl
public interface ElasticsearchClientLow-level operations for Elasticsearch. Doesn't know anything about aliases, this must be handled in the layer above.
-
-
Nested Class Summary
Nested Classes Modifier and Type Interface Description static interfaceElasticsearchClient.BulkRequestClient
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description ElasticsearchClient.BulkRequestClientbulkRequest()voidcreateAliasForIndex(String alias, String index)Creates a new alias for the given index.voidcreateCustomAlias(String alias, String indexMapping)com.fasterxml.jackson.databind.JsonNodecreateIndex(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.voiddeleteAliasAndRelatedIndices(String alias)voiddeleteAliasForIndex(String alias, String index)voiddeleteAllIndicesWithPrefix(String prefix)voiddeleteByQuery(String index, com.fasterxml.jackson.databind.node.ObjectNode requestNode)voiddeleteDocument(String alias, String id)voiddeleteIndexIfExists(String index)com.fasterxml.jackson.databind.JsonNodegetById(String index, String id)com.fasterxml.jackson.databind.JsonNodegetIndexCurrentMapping(String index)com.fasterxml.jackson.databind.JsonNodegetIndexCurrentSettings(String index)StringgetIndexNameForAlias(String alias)com.fasterxml.jackson.databind.JsonNodegetVersionInformation()booleanindexExists(String index)com.fasterxml.jackson.databind.JsonNodequery(String index, com.fasterxml.jackson.databind.node.ObjectNode queryBody)com.fasterxml.jackson.databind.JsonNodequery(String index, String queryBody)voidrefreshIndex(String index)voidswapAlias(String alias, String oldIndexName, String newIndexName)Swaps the alias from one index to another index.voidsynchronousIndexDocumentRequest(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.voidsynchronousUpdateDocumentRequest(String index, String id, com.fasterxml.jackson.databind.node.ObjectNode objectNode, com.fasterxml.jackson.databind.node.ObjectNode scriptNode)voidsynchronousUpsertDocumentRequest(String index, String id, com.fasterxml.jackson.databind.node.ObjectNode objectNode)Indexes a document using an upsert queryvoidupdateAliasMapping(String indexName, String aliasName, com.fasterxml.jackson.databind.JsonNode indexMapping)voidupdateByQuery(String index, com.fasterxml.jackson.databind.node.ObjectNode requestNode)voidupdateIndexMapping(String indexName, com.fasterxml.jackson.databind.JsonNode mappingDelta)voidupdateIndexMetaData(String index, com.fasterxml.jackson.databind.JsonNode metaData)
-
-
-
Method Detail
-
getVersionInformation
com.fasterxml.jackson.databind.JsonNode getVersionInformation()
-
createIndex
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.- 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
void createAliasForIndex(String alias, String index)
Creates a new alias for the given index.
-
swapAlias
void swapAlias(String alias, String oldIndexName, String newIndexName)
Swaps the alias from one index to another index.
-
synchronousUpsertDocumentRequest
void synchronousUpsertDocumentRequest(String index, String id, com.fasterxml.jackson.databind.node.ObjectNode objectNode)
Indexes a document using an upsert query
-
synchronousIndexDocumentRequest
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. Update API is not available for external versioning.
-
synchronousUpdateDocumentRequest
void synchronousUpdateDocumentRequest(String index, String id, com.fasterxml.jackson.databind.node.ObjectNode objectNode, com.fasterxml.jackson.databind.node.ObjectNode scriptNode)
-
updateByQuery
void updateByQuery(String index, com.fasterxml.jackson.databind.node.ObjectNode requestNode)
-
deleteByQuery
void deleteByQuery(String index, com.fasterxml.jackson.databind.node.ObjectNode requestNode)
-
deleteAliasAndRelatedIndices
void deleteAliasAndRelatedIndices(String alias)
-
deleteIndexIfExists
void deleteIndexIfExists(String index)
-
deleteAllIndicesWithPrefix
void deleteAllIndicesWithPrefix(String prefix)
-
indexExists
boolean indexExists(String index)
-
refreshIndex
void refreshIndex(String index)
-
query
com.fasterxml.jackson.databind.JsonNode query(String index, com.fasterxml.jackson.databind.node.ObjectNode queryBody)
-
getIndexCurrentMapping
com.fasterxml.jackson.databind.JsonNode getIndexCurrentMapping(String index)
-
getIndexCurrentSettings
com.fasterxml.jackson.databind.JsonNode getIndexCurrentSettings(String index)
-
updateIndexMetaData
void updateIndexMetaData(String index, com.fasterxml.jackson.databind.JsonNode metaData)
-
updateAliasMapping
void updateAliasMapping(String indexName, String aliasName, com.fasterxml.jackson.databind.JsonNode indexMapping)
-
updateIndexMapping
void updateIndexMapping(String indexName, com.fasterxml.jackson.databind.JsonNode mappingDelta)
-
bulkRequest
ElasticsearchClient.BulkRequestClient bulkRequest()
-
-