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(String indexName,
IndexManagerHolder indexManagerHolder) |
List<LuceneWork> |
WorkQueue.getSealedQueue() |
Modifier and Type | Method and Description |
---|---|
void |
LocalBackendQueueProcessor.applyStreamWork(LuceneWork singleOperation,
IndexingMonitor monitor) |
void |
TransactionalOperationExecutor.performOperation(LuceneWork work,
IndexShardingStrategy shardingStrategy,
WorkQueuePerIndexSplitter context)
The LuceneWork must be applied to different indexes.
|
void |
StreamingOperationExecutor.performStreamOperation(LuceneWork work,
IndexShardingStrategy shardingStrategy,
IndexingMonitor monitor,
boolean forceAsync)
The LuceneWork must be applied to different indexes.
|
Modifier and Type | Method and Description |
---|---|
void |
LocalBackendQueueProcessor.applyWork(List<LuceneWork> workList,
IndexingMonitor monitor) |
Modifier and Type | Method and Description |
---|---|
void |
DefaultBatchBackend.doWorkInSync(LuceneWork work) |
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 |
---|---|
Iterator<LuceneWork> |
ChangesetList.iterator() |
Modifier and Type | Method and Description |
---|---|
void |
WorkspaceHolder.applyStreamWork(LuceneWork singleOperation,
IndexingMonitor monitor) |
void |
SharedIndexWorkspaceImpl.notifyWorkApplied(LuceneWork work) |
void |
ExclusiveIndexWorkspaceImpl.notifyWorkApplied(LuceneWork work) |
void |
NRTWorkspaceImpl.notifyWorkApplied(LuceneWork work) |
Modifier and Type | Method and Description |
---|---|
void |
WorkspaceHolder.applyWork(List<LuceneWork> workList,
IndexingMonitor monitor) |
Constructor and Description |
---|
Changeset(List<LuceneWork> workList,
Thread producer,
IndexingMonitor monitor) |
Modifier and Type | Method and Description |
---|---|
void |
LuceneWorkExecutor.performWork(LuceneWork work,
IndexWriterDelegate delegate,
IndexingMonitor monitor)
Will perform work on an IndexWriter.
|
void |
UpdateWorkExecutor.performWork(LuceneWork work,
IndexWriterDelegate delegate,
IndexingMonitor monitor) |
void |
UpdateExtWorkExecutor.performWork(LuceneWork work,
IndexWriterDelegate delegate,
IndexingMonitor monitor) |
void |
DeleteExtWorkExecutor.performWork(LuceneWork work,
IndexWriterDelegate delegate,
IndexingMonitor monitor) |
void |
ByTermDeleteWorkExecutor.performWork(LuceneWork work,
IndexWriterDelegate delegate,
IndexingMonitor monitor) |
void |
ByTermUpdateWorkExecutor.performWork(LuceneWork work,
IndexWriterDelegate delegate,
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,
JmsBackendQueueProcessor jmsBackendQueueProcessor,
LuceneWorkSerializer luceneWorkSerializer) |
Modifier and Type | Class and Description |
---|---|
class |
DeleteByQueryLuceneWork
Representation of deleteByQuery(...) from Lucene.
|
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) |
void |
BatchBackend.doWorkInSync(LuceneWork work)
Does one work in sync
|
void |
BatchBackend.enqueueAsyncWork(LuceneWork work)
Enqueues one work to be processed asynchronously
|
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 |
---|---|
LuceneWork |
BackendRequest.getLuceneWork()
Returns the original Lucene work from which this request was derived.
|
Constructor and Description |
---|
BackendRequest(io.searchbox.action.Action<T> action,
LuceneWork luceneWork,
String indexName,
BackendRequestResultAssessor<? super T> resultAssessor,
IndexingMonitor indexingMonitor,
BackendRequestSuccessReporter<? super T> successReporter,
boolean refreshAfterWrite) |
Modifier and Type | Method and Description |
---|---|
void |
ElasticsearchIndexManager.performStreamOperation(LuceneWork singleOperation,
IndexingMonitor monitor,
boolean forceAsync) |
Modifier and Type | Method and Description |
---|---|
void |
ElasticsearchIndexManager.performOperations(List<LuceneWork> workList,
IndexingMonitor monitor) |
Modifier and Type | Method and Description |
---|---|
List<LuceneWork> |
WorkPlan.getPlannedLuceneWork() |
Modifier and Type | Method and Description |
---|---|
abstract void |
AbstractDocumentBuilder.addWorkToQueue(String tenantIdentifier,
Class<?> entityClass,
Object entity,
Serializable id,
boolean delete,
boolean add,
List<LuceneWork> queue,
ConversionContext contextualBridge) |
void |
DocumentBuilderContainedEntity.addWorkToQueue(String tenantId,
Class<?> entityClass,
Object entity,
Serializable id,
boolean delete,
boolean add,
List<LuceneWork> queue,
ConversionContext contextualBridge) |
void |
DocumentBuilderIndexedEntity.addWorkToQueue(String tenantId,
Class<?> entityClass,
Object 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(Iterable<LuceneWork> workOnWriter) |
Modifier and Type | Method and Description |
---|---|
void |
AvroSerializer.luceneWorks(List<LuceneWork> works) |
Modifier and Type | Method and Description |
---|---|
List<LuceneWork> |
LuceneWorkHydrator.getLuceneWorks() |
List<LuceneWork> |
LuceneWorkSerializerImpl.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[] |
LuceneWorkSerializerImpl.toSerializedModel(List<LuceneWork> works)
Convert a List of LuceneWork into a byte[]
|
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.
|
void |
DirectoryBasedIndexManager.performStreamOperation(LuceneWork singleOperation,
IndexingMonitor monitor,
boolean forceAsync) |
Modifier and Type | Method and Description |
---|---|
void |
IndexManager.performOperations(List<LuceneWork> queue,
IndexingMonitor monitor)
Used to apply update operations to the index.
|
void |
DirectoryBasedIndexManager.performOperations(List<LuceneWork> workList,
IndexingMonitor monitor) |
Modifier and Type | Method and Description |
---|---|
void |
Workspace.notifyWorkApplied(LuceneWork work)
Deprecated.
Some workspaces need this to determine for example the kind of flush operations which are safe
to apply.
|
Copyright © 2006-2017 Red Hat, Inc. All Rights Reserved