Package com.atlassian.confluence.plugins.opensearch.bulk

Class OpenSearchBulkIndexWriter

java.lang.Object

com.atlassian.confluence.plugins.opensearch.bulk.OpenSearchBulkIndexWriter

All Implemented Interfaces:

SearchIndexWriter

public class OpenSearchBulkIndexWriter
extends Object
implements SearchIndexWriter

An index writer that uses OpenSearch bulk API.

Since:

8.7

Field Summary

Fields

Modifier and Type	Field	Description
static final int	MAX_DOCS
static final int	OPTIMIZE_RAM_DEFAULT
static final String	OPTIMIZE_RAM_PROPERTY

Constructor Summary

Constructors

Constructor	Description
OpenSearchBulkIndexWriter(org.opensearch.client.opensearch.OpenSearchClient client, OpenSearchIndexManager indexManager, String indexName, DelegatingQueryMapper queryMapper, io.github.resilience4j.retry.RetryRegistry retryRegistry)

Method Summary

Modifier and Type	Method	Description
void	add(AtlassianDocument document)
protected Map<String,Collection<Object>>	convert(AtlassianDocument document)
void	delete(SearchQuery searchQuery)
void	deleteAll()
void	flush()
BulkOperationBuffer	getBuffer()
void	postOptimize()
void	preOptimize()
void	update(String documentId, AtlassianDocument document)	Applies partial updates to the document with the given id.

Methods inherited from class java.lang.Object

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

Field Details

MAX_DOCS

public static final int MAX_DOCS

See Also:

• Constant Field Values

OPTIMIZE_RAM_PROPERTY

public static final String OPTIMIZE_RAM_PROPERTY

See Also:

• Constant Field Values

OPTIMIZE_RAM_DEFAULT

public static final int OPTIMIZE_RAM_DEFAULT

See Also:

• Constant Field Values

Constructor Details

OpenSearchBulkIndexWriter

public OpenSearchBulkIndexWriter(org.opensearch.client.opensearch.OpenSearchClient client,
 OpenSearchIndexManager indexManager,
 String indexName,
 DelegatingQueryMapper queryMapper,
 io.github.resilience4j.retry.RetryRegistry retryRegistry)

Method Details

getBuffer

public BulkOperationBuffer getBuffer()

add

public void add(AtlassianDocument document)
         throws IOException

Specified by:

add in interface SearchIndexWriter

Throws:

IOException

delete

public void delete(SearchQuery searchQuery)
            throws IOException

Specified by:

delete in interface SearchIndexWriter

Throws:

IOException

deleteAll

public void deleteAll()
               throws IOException

Specified by:

deleteAll in interface SearchIndexWriter

Throws:

IOException

flush

public void flush()
           throws IOException

Throws:

IOException

preOptimize

public void preOptimize()

Specified by:

preOptimize in interface SearchIndexWriter

postOptimize

public void postOptimize()

Specified by:

postOptimize in interface SearchIndexWriter

convert

protected Map<String,Collection<Object>> convert(AtlassianDocument document)

update

public void update(String documentId,
 AtlassianDocument document)
            throws IOException

Description copied from interface: SearchIndexWriter

Applies partial updates to the document with the given id. The updates applied are the fields specified in the document passed as an argument. OpenSearch Only. DO NOT USE for Lucene.

Specified by:

update in interface SearchIndexWriter

Parameters:

documentId - ID of the existing document to be updated

document - The partial update to be applied to the existing document

Throws:

IOException