public interface DocStoreUpdateProcessor
This involves sending updates directly to ElasticSearch via it's Bulk API or queuing events for future processing.
Modifier and Type | Method and Description |
---|---|
void |
commit(DocStoreTransaction docStoreTransaction)
Perform commit/flush of the changes made via the document store transaction.
|
<T> DocStoreQueryUpdate<T> |
createQueryUpdate(BeanType<T> beanType,
int bulkBatchSize)
Create a processor to handle updates per bean via a findEach query.
|
DocStoreTransaction |
createTransaction(int batchSize)
Create a document store transaction hinting at the batch size.
|
void |
process(DocStoreUpdates docStoreUpdates,
int bulkBatchSize)
Process all the updates for a transaction.
|
<T> DocStoreQueryUpdate<T> createQueryUpdate(BeanType<T> beanType, int bulkBatchSize) throws IOException
IOException
void process(DocStoreUpdates docStoreUpdates, int bulkBatchSize)
Typically this makes calls to the Bulk API of the document store or simply adds entries to a queue for future processing.
docStoreUpdates
- The 'Bulk' and 'Queue' updates to the indexes for the transaction.bulkBatchSize
- The batch size to use for Bulk API calls specified on the transaction.
If this is 0 then the default batch size is used.DocStoreTransaction createTransaction(int batchSize)
The batch size can be set via Transaction.setDocStoreBatchSize(int)
void commit(DocStoreTransaction docStoreTransaction)
Copyright © 2019. All rights reserved.