Modifier and Type | Class and Description |
---|---|
class |
AddLuceneWork |
class |
DeleteLuceneWork |
class |
FlushLuceneWork
Used to flush and commit asynchronous and other pending operations on the Indexes.
|
class |
OptimizeLuceneWork
A unit of work triggering an optimize operation.
|
class |
PurgeAllLuceneWork
A unit of work used to purge an entire index.
|
class |
UpdateLuceneWork
Carries a Lucene update operation from the engine to the backend
|
Modifier and Type | Method and Description |
---|---|
List<LuceneWork> |
WorkQueuePerIndexSplitter.getIndexManagerQueue(IndexManager indexManager) |
List<LuceneWork> |
WorkQueue.getSealedQueue() |
Modifier and Type | Method and Description |
---|---|
void |
ContextAwareSelectionDelegate.performOperation(LuceneWork work,
IndexShardingStrategy shardingStrategy,
WorkQueuePerIndexSplitter context)
The LuceneWork must be applied to different indexes.
|
void |
StreamingOperationSelectionDelegate.performStreamOperation(LuceneWork work,
IndexShardingStrategy shardingStrategy,
IndexingMonitor monitor,
boolean forceAsync)
The LuceneWork must be applied to different indexes.
|
Modifier and Type | Method and Description |
---|---|
void |
BatchBackend.doWorkInSync(LuceneWork work)
Does one work in sync
|
void |
DefaultBatchBackend.doWorkInSync(LuceneWork work) |
void |
BatchBackend.enqueueAsyncWork(LuceneWork work)
Enqueues one work to be processed asynchronously
|
void |
DefaultBatchBackend.enqueueAsyncWork(LuceneWork work) |
Modifier and Type | Method and Description |
---|---|
void |
BlackHoleBackendQueueProcessor.applyStreamWork(LuceneWork singleOperation,
IndexingMonitor monitor) |
Modifier and Type | Method and Description |
---|---|
void |
BlackHoleBackendQueueProcessor.applyWork(List<LuceneWork> workList,
IndexingMonitor monitor) |
Modifier and Type | Method and Description |
---|---|
void |
JGroupsBackendQueueProcessor.applyStreamWork(LuceneWork singleOperation,
IndexingMonitor monitor) |
Modifier and Type | Method and Description |
---|---|
void |
JGroupsBackendQueueProcessor.applyWork(List<LuceneWork> workList,
IndexingMonitor monitor) |
void |
JGroupsBackendQueueTask.sendLuceneWorkList(List<LuceneWork> queue) |
Modifier and Type | Method and Description |
---|---|
void |
JmsBackendQueueProcessor.applyStreamWork(LuceneWork singleOperation,
IndexingMonitor monitor) |
Modifier and Type | Method and Description |
---|---|
void |
JmsBackendQueueProcessor.applyWork(List<LuceneWork> workList,
IndexingMonitor monitor) |
Constructor and Description |
---|
JmsBackendQueueTask(String indexName,
Collection<LuceneWork> queue,
IndexManager indexManager,
JmsBackendQueueProcessor jmsBackendQueueProcessor) |
Modifier and Type | Method and Description |
---|---|
Iterator<LuceneWork> |
ChangesetList.iterator() |
Modifier and Type | Method and Description |
---|---|
void |
LuceneBackendQueueProcessor.applyStreamWork(LuceneWork singleOperation,
IndexingMonitor monitor) |
void |
ExclusiveIndexWorkspaceImpl.notifyWorkApplied(LuceneWork work) |
void |
NRTWorkspaceImpl.notifyWorkApplied(LuceneWork work) |
void |
SharedIndexWorkspaceImpl.notifyWorkApplied(LuceneWork work) |
Modifier and Type | Method and Description |
---|---|
void |
LuceneBackendQueueProcessor.applyWork(List<LuceneWork> workList,
IndexingMonitor monitor) |
Constructor and Description |
---|
SingleTaskRunnable(LuceneWork work,
LuceneBackendResources resources,
IndexWriter indexWriter,
IndexingMonitor monitor) |
Constructor and Description |
---|
Changeset(List<LuceneWork> workList,
Thread producer,
IndexingMonitor monitor) |
Modifier and Type | Method and Description |
---|---|
void |
ByTermDeleteWorkDelegate.performWork(LuceneWork work,
IndexWriter writer,
IndexingMonitor monitor) |
void |
ByTermUpdateWorkDelegate.performWork(LuceneWork work,
IndexWriter writer,
IndexingMonitor monitor) |
void |
DeleteExtWorkDelegate.performWork(LuceneWork work,
IndexWriter writer,
IndexingMonitor monitor) |
void |
LuceneWorkDelegate.performWork(LuceneWork work,
IndexWriter writer,
IndexingMonitor monitor)
Will perform work on an IndexWriter.
|
void |
UpdateExtWorkDelegate.performWork(LuceneWork work,
IndexWriter writer,
IndexingMonitor monitor) |
void |
UpdateWorkDelegate.performWork(LuceneWork work,
IndexWriter writer,
IndexingMonitor monitor) |
Modifier and Type | Method and Description |
---|---|
void |
BackendQueueProcessor.applyStreamWork(LuceneWork singleOperation,
IndexingMonitor monitor)
Applies a single operation on the index, and different operations can be applied in parallel,
even in parallel to a workList instance being processed by
BackendQueueProcessor.applyWork(List, IndexingMonitor) |
Modifier and Type | Method and Description |
---|---|
void |
BackendQueueProcessor.applyWork(List<LuceneWork> workList,
IndexingMonitor monitor)
Applies a list of operations to the index.
|
Modifier and Type | Method and Description |
---|---|
List<LuceneWork> |
WorkPlan.getPlannedLuceneWork() |
Modifier and Type | Method and Description |
---|---|
abstract void |
AbstractDocumentBuilder.addWorkToQueue(Class<T> entityClass,
T entity,
Serializable id,
boolean delete,
boolean add,
List<LuceneWork> queue,
ConversionContext contextualBridge) |
void |
DocumentBuilderContainedEntity.addWorkToQueue(Class<T> entityClass,
T entity,
Serializable id,
boolean delete,
boolean add,
List<LuceneWork> queue,
ConversionContext contextualBridge) |
void |
DocumentBuilderIndexedEntity.addWorkToQueue(Class<T> entityClass,
T entity,
Serializable id,
boolean delete,
boolean add,
List<LuceneWork> queue,
ConversionContext contextualBridge) |
Modifier and Type | Method and Description |
---|---|
LuceneWork |
ErrorContext.getOperationAtFault() |
Modifier and Type | Method and Description |
---|---|
List<LuceneWork> |
ErrorContext.getFailingOperations() |
Modifier and Type | Method and Description |
---|---|
ErrorContextBuilder |
ErrorContextBuilder.addWorkThatFailed(LuceneWork failedWork) |
static void |
LogErrorHandler.appendFailureMessage(StringBuilder message,
LuceneWork workThatFailed) |
ErrorContextBuilder |
ErrorContextBuilder.workCompleted(LuceneWork luceneWork) |
Modifier and Type | Method and Description |
---|---|
ErrorContextBuilder |
ErrorContextBuilder.addAllWorkThatFailed(List<LuceneWork> worksThatFailed) |
ErrorContextBuilder |
ErrorContextBuilder.allWorkToBeDone(List<LuceneWork> workOnWriter) |
Modifier and Type | Method and Description |
---|---|
void |
DirectoryBasedIndexManager.performStreamOperation(LuceneWork singleOperation,
IndexingMonitor monitor,
boolean forceAsync) |
Modifier and Type | Method and Description |
---|---|
void |
DirectoryBasedIndexManager.performOperations(List<LuceneWork> workList,
IndexingMonitor monitor) |
Modifier and Type | Method and Description |
---|---|
void |
AvroSerializer.luceneWorks(List<LuceneWork> works) |
Modifier and Type | Method and Description |
---|---|
List<LuceneWork> |
LuceneWorkHydrator.getLuceneWorks() |
List<LuceneWork> |
PluggableSerializationLuceneWorkSerializer.toLuceneWorks(byte[] data)
Convert a byte[] to a List of LuceneWork (assuming the same SerializationProvider is used of course)
|
Modifier and Type | Method and Description |
---|---|
byte[] |
PluggableSerializationLuceneWorkSerializer.toSerializedModel(List<LuceneWork> works)
Convert a List of LuceneWork into a byte[]
|
Modifier and Type | Method and Description |
---|---|
void |
JavaSerializationSerializer.luceneWorks(List<LuceneWork> works) |
Modifier and Type | Method and Description |
---|---|
List<LuceneWork> |
LuceneWorkSerializer.toLuceneWorks(byte[] data)
Convert a byte[] to a List of LuceneWork
|
Modifier and Type | Method and Description |
---|---|
void |
Serializer.luceneWorks(List<LuceneWork> works) |
byte[] |
LuceneWorkSerializer.toSerializedModel(List<LuceneWork> works)
Convert a List of LuceneWork into a byte[]
|
Modifier and Type | Method and Description |
---|---|
void |
IndexManager.performStreamOperation(LuceneWork singleOperation,
IndexingMonitor monitor,
boolean forceAsync)
Perform a single non-transactional operation, best to stream large amounts of operations.
|
Modifier and Type | Method and Description |
---|---|
void |
IndexManager.performOperations(List<LuceneWork> queue,
IndexingMonitor monitor)
Used to apply update operations to the index.
|
Modifier and Type | Method and Description |
---|---|
void |
Workspace.notifyWorkApplied(LuceneWork work)
Some workspaces need this to determine for example the kind of flush operations which are safe
to apply.
|
Copyright © 2006-2015 Red Hat, Inc. All Rights Reserved