public class WorkQueuePerIndexSplitter extends Object
TransactionalOperationExecutor
to split a list of operations
according to the multiple IndexManagers it needs to be routed to.Constructor and Description |
---|
WorkQueuePerIndexSplitter(IndexManagerHolder indexManagerHolder,
Predicate<IndexManager> indexManagerFilter) |
Modifier and Type | Method and Description |
---|---|
void |
addToQueue(IndexManager indexManager,
LuceneWork work) |
void |
commitOperations(IndexingMonitor monitor)
Send all operations stored so far to the backend to be performed, atomically and/or transactionally
if supported/enabled by each specific backend.
|
void |
performStreamOperation(IndexManager indexManager,
LuceneWork work) |
public WorkQueuePerIndexSplitter(IndexManagerHolder indexManagerHolder, Predicate<IndexManager> indexManagerFilter)
public void addToQueue(IndexManager indexManager, LuceneWork work)
public void performStreamOperation(IndexManager indexManager, LuceneWork work)
public void commitOperations(IndexingMonitor monitor)
monitor
- a IndexingMonitor
object.Copyright © 2006-2017 Red Hat, Inc. All Rights Reserved