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

Class MaxDocsBulkOperationBuffer

java.lang.Object

com.atlassian.confluence.plugins.opensearch.bulk.MaxDocsBulkOperationBuffer

All Implemented Interfaces:

BulkOperationBuffer

public class MaxDocsBulkOperationBuffer
extends Object
implements BulkOperationBuffer

Applies automatic flush to a delegate BulkOperationBuffer whenever the number of enqueued documents have reached the specified limit.

Since:

9.0

Constructor Summary

Constructors

Constructor	Description
MaxDocsBulkOperationBuffer(BulkOperationBuffer delegate, int limit)

Method Summary

Modifier and Type	Method	Description
void	add(org.opensearch.client.opensearch.core.bulk.BulkOperation op)	Add a bulk operation to the buffer.
void	flush()	Send all pending bulk operations in the buffer to OpenSearch bulk API
BulkOperationBuffer	getDelegate()
int	getLimit()

Methods inherited from class java.lang.Object

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

Constructor Details

MaxDocsBulkOperationBuffer

public MaxDocsBulkOperationBuffer(BulkOperationBuffer delegate,
 int limit)

Method Details

add

public void add(org.opensearch.client.opensearch.core.bulk.BulkOperation op)
         throws IOException

Description copied from interface: BulkOperationBuffer

Add a bulk operation to the buffer. Adding an operation might trigger a flush depending on the implementation.

Specified by:

add in interface BulkOperationBuffer

Parameters:

op - The operation to add to the buffer

Throws:

IOException

flush

public void flush()
           throws IOException

Description copied from interface: BulkOperationBuffer

Send all pending bulk operations in the buffer to OpenSearch bulk API

Specified by:

flush in interface BulkOperationBuffer

Throws:

IOException

getDelegate

public BulkOperationBuffer getDelegate()

getLimit

public int getLimit()