Interface ElasticsearchWorkFactory
- All Known Implementing Classes:
AmazonOpenSearchServerlessWorkFactory,Elasticsearch7WorkFactory
public interface ElasticsearchWorkFactory
-
Method Summary
Modifier and TypeMethodDescriptionanalyze(URLEncodedString indexName, String text, String analyzer, String normalizer) bulk(List<? extends BulkableWork<?>> bulkableWorks) clearScroll(String scrollId) closeIndex(URLEncodedString indexName) count()createIndex(URLEncodedString indexName) delete(String entityTypeName, Object entityIdentifier, URLEncodedString elasticsearchIndexName, String documentIdentifier, String routingKey) deleteByQuery(URLEncodedString indexName, com.google.gson.JsonObject payload) dropIndex(URLEncodedString indexName) explain(URLEncodedString indexName, URLEncodedString id, com.google.gson.JsonObject payload) flush()index(String entityTypeName, Object entityIdentifier, URLEncodedString elasticsearchIndexName, String documentIdentifier, String routingKey, com.google.gson.JsonObject document) booleanbooleanbooleanbooleanbooleanopenIndex(URLEncodedString indexName) putIndexAliases(URLEncodedString indexName, Map<String, IndexAliasDefinition> aliases) putIndexSettings(URLEncodedString indexName, IndexSettings settings) putIndexTypeMapping(URLEncodedString indexName, RootTypeMapping mapping) refresh()<T> ScrollWork.Builder<T>scroll(String scrollId, String scrollTimeout, ElasticsearchSearchResultExtractor<T> searchResultExtractor) <T> SearchWork.Builder<T>search(com.google.gson.JsonObject payload, ElasticsearchSearchResultExtractor<T> searchResultExtractor) waitForIndexStatus(URLEncodedString indexName, IndexStatus requiredStatus, int requiredStatusTimeoutInMs)
-
Method Details
-
index
IndexWork.Builder index(String entityTypeName, Object entityIdentifier, URLEncodedString elasticsearchIndexName, String documentIdentifier, String routingKey, com.google.gson.JsonObject document) -
delete
DeleteWork.Builder delete(String entityTypeName, Object entityIdentifier, URLEncodedString elasticsearchIndexName, String documentIdentifier, String routingKey) -
isDeleteByQuerySupported
boolean isDeleteByQuerySupported() -
deleteByQuery
DeleteByQueryWork.Builder deleteByQuery(URLEncodedString indexName, com.google.gson.JsonObject payload) -
isFlushSupported
boolean isFlushSupported() -
flush
FlushWork.Builder flush() -
isRefreshSupported
boolean isRefreshSupported() -
refresh
RefreshWork.Builder refresh() -
isMergeSegmentsSupported
boolean isMergeSegmentsSupported() -
mergeSegments
ForceMergeWork.Builder mergeSegments() -
bulk
-
search
<T> SearchWork.Builder<T> search(com.google.gson.JsonObject payload, ElasticsearchSearchResultExtractor<T> searchResultExtractor) -
count
CountWork.Builder count() -
explain
ExplainWork.Builder explain(URLEncodedString indexName, URLEncodedString id, com.google.gson.JsonObject payload) -
scroll
<T> ScrollWork.Builder<T> scroll(String scrollId, String scrollTimeout, ElasticsearchSearchResultExtractor<T> searchResultExtractor) -
clearScroll
-
createIndex
-
dropIndex
-
openIndex
-
closeIndex
-
getIndexMetadata
GetIndexMetadataWork.Builder getIndexMetadata() -
putIndexSettings
-
putIndexTypeMapping
PutIndexMappingWork.Builder putIndexTypeMapping(URLEncodedString indexName, RootTypeMapping mapping) -
isWaitForIndexStatusSupported
boolean isWaitForIndexStatusSupported() -
waitForIndexStatus
WaitForIndexStatusWork.Builder waitForIndexStatus(URLEncodedString indexName, IndexStatus requiredStatus, int requiredStatusTimeoutInMs) -
putIndexAliases
PutIndexAliasesWork.Builder putIndexAliases(URLEncodedString indexName, Map<String, IndexAliasDefinition> aliases) -
analyze
AnalyzeWork.Builder analyze(URLEncodedString indexName, String text, String analyzer, String normalizer)
-