com.atlassian.confluence.search.elasticsearch

Class ESIndexQueueFlusher

java.lang.Object

com.atlassian.confluence.search.elasticsearch.ESIndexQueueFlusher

@Internal
public class ESIndexQueueFlusher
extends Object

Flushes the index queue to Elasticsearch.

Since:

5.9.

Constructor Summary

Constructors

Constructor and Description
ESIndexQueueFlusher(ESFeatureManager esFeatureManager, IndexTaskQueue<ESTask> esIndexTaskQueue, org.elasticsearch.client.Client client, org.springframework.transaction.PlatformTransactionManager transactionManager)

Method Summary

Modifier and Type	Method and Description
boolean	flushFirstBatch() To avoid system load, this method does not flush the entire queue at a time.

Methods inherited from class java.lang.Object

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

Constructor Detail

ESIndexQueueFlusher

public ESIndexQueueFlusher(ESFeatureManager esFeatureManager,
                           IndexTaskQueue<ESTask> esIndexTaskQueue,
                           org.elasticsearch.client.Client client,
                           org.springframework.transaction.PlatformTransactionManager transactionManager)

Method Detail

flushFirstBatch

public boolean flushFirstBatch()

To avoid system load, this method does not flush the entire queue at a time.

Returns:

whether the flush actually took place