Index

A B C D E F G H I J L M N O P R S T U V W
All Classes and Interfaces|All Packages|Constant Field Values|Serialized Form

A

apply(CategoryDeleteCascadeSource) - Method in class org.alfresco.elasticsearch.batchindexing.cascade.CategoryDeleteCascadeService

Apply the category-delete cascade for one source.

apply(RenameCascadeSource) - Method in class org.alfresco.elasticsearch.batchindexing.cascade.RenameCascadeService

Apply the rename cascade for one source.

B

BatchIndexingApp - Class in org.alfresco.elasticsearch.batchindexing

BatchIndexingApp(ElasticsearchReindexProperties, ContinuousReindexingProperties) - Constructor for class org.alfresco.elasticsearch.batchindexing.BatchIndexingApp

BatchIndexingBatchConfig - Class in org.alfresco.elasticsearch.batchindexing.config

Bean wiring for the batch-indexing processing pipeline.

BatchIndexingBatchConfig() - Constructor for class org.alfresco.elasticsearch.batchindexing.config.BatchIndexingBatchConfig

beforeJob(JobExecution) - Method in class org.alfresco.elasticsearch.batchindexing.listeners.CacheInvalidationListener

bootstrap() - Method in class org.alfresco.elasticsearch.batchindexing.WatermarkBootstrap

Run the startup dance: enforce the state-index guard, ensure the state index exists, seed the cursor from the Alfresco index if applicable, enforce the Alfresco-index presence guard.

C

cacheInvalidationListener(AlfrescoMetadataRepository) - Method in class org.alfresco.elasticsearch.batchindexing.config.ContinuousReindexingConfig

CacheInvalidationListener - Class in org.alfresco.elasticsearch.batchindexing.listeners

Invalidates the tag and child-association caches in the Alfresco metadata repository before every batch indexing job run.

CacheInvalidationListener(AlfrescoMetadataRepository) - Constructor for class org.alfresco.elasticsearch.batchindexing.listeners.CacheInvalidationListener

cascadeCollectorWriter(CascadeSourceStash, SourceDocLookup) - Method in class org.alfresco.elasticsearch.batchindexing.config.CascadeConfig

CascadeCollectorWriter - Class in org.alfresco.elasticsearch.batchindexing.cascade

Observer ItemWriter that scans events for cascade signals and stashes enriched sources for the post-cycle sweep.

CascadeCollectorWriter(CascadeSourceStash, SourceDocLookup) - Constructor for class org.alfresco.elasticsearch.batchindexing.cascade.CascadeCollectorWriter

CascadeConfig - Class in org.alfresco.elasticsearch.batchindexing.config

Bean wiring for the batch-indexing cascade support.

CascadeConfig() - Constructor for class org.alfresco.elasticsearch.batchindexing.config.CascadeConfig

CascadeProperties - Class in org.alfresco.elasticsearch.batchindexing.config

Configuration properties for the batch-indexing cascade support.

CascadeProperties() - Constructor for class org.alfresco.elasticsearch.batchindexing.config.CascadeProperties

CascadeSourceBatch - Record Class in org.alfresco.elasticsearch.batchindexing.cascade

Snapshot of cascade sources drained from CascadeSourceStash at the end of a reindex cycle.

CascadeSourceBatch(List<RenameCascadeSource>, List<CategoryDeleteCascadeSource>) - Constructor for record class org.alfresco.elasticsearch.batchindexing.cascade.CascadeSourceBatch

Creates an instance of a CascadeSourceBatch record class.

cascadeSourceDocLookup(OpenSearchClient, ElasticsearchProperties) - Method in class org.alfresco.elasticsearch.batchindexing.config.CascadeConfig

cascadeSourceStash() - Method in class org.alfresco.elasticsearch.batchindexing.config.CascadeConfig

CascadeSourceStash - Class in org.alfresco.elasticsearch.batchindexing.cascade

Thread-safe, cycle-scoped bag of cascade sources observed during a batch-indexing cycle.

CascadeSourceStash() - Constructor for class org.alfresco.elasticsearch.batchindexing.cascade.CascadeSourceStash

cascadeSweepService(CascadeSourceStash, RenameCascadeService, CategoryDeleteCascadeService) - Method in class org.alfresco.elasticsearch.batchindexing.config.CascadeConfig

CascadeSweepService - Class in org.alfresco.elasticsearch.batchindexing.cascade

Post-cycle orchestrator that drains the CascadeSourceStash once a reindexByDate cycle finishes successfully and dispatches each observed cascade source to the appropriate cascade service.

CascadeSweepService(CascadeSourceStash, RenameCascadeService, CategoryDeleteCascadeService) - Constructor for class org.alfresco.elasticsearch.batchindexing.cascade.CascadeSweepService

categoryDeleteCascadeService(OpenSearchClient, ElasticsearchProperties, CascadeProperties) - Method in class org.alfresco.elasticsearch.batchindexing.config.CascadeConfig

CategoryDeleteCascadeService - Class in org.alfresco.elasticsearch.batchindexing.cascade

Cascades a category delete by pruning the deleted UUID from every referring document's CategoryDeleteCascadeService.CATEGORIES_FIELD (cm%3Acategories), CATEGORY_ANCESTOR and PARENT arrays, and stripping PATH / UNPREFIXED_PATH entries that contain any of the deleted category's paths, via a single _update_by_query.

CategoryDeleteCascadeService(OpenSearchClient, ElasticsearchProperties, CascadeProperties) - Constructor for class org.alfresco.elasticsearch.batchindexing.cascade.CategoryDeleteCascadeService

CategoryDeleteCascadeSource - Record Class in org.alfresco.elasticsearch.batchindexing.cascade

Descriptor for a delete event that corresponds to a cm:category node.

CategoryDeleteCascadeSource(String, String, List<String>, List<String>) - Constructor for record class org.alfresco.elasticsearch.batchindexing.cascade.CategoryDeleteCascadeSource

Creates an instance of a CategoryDeleteCascadeSource record class.

categoryDeleteCount() - Method in class org.alfresco.elasticsearch.batchindexing.cascade.CascadeSourceStash

categoryDeletes() - Method in record class org.alfresco.elasticsearch.batchindexing.cascade.CascadeSourceBatch

Returns the value of the categoryDeletes record component.

clear() - Method in class org.alfresco.elasticsearch.batchindexing.cascade.CascadeSourceStash

clearStash() - Method in class org.alfresco.elasticsearch.batchindexing.cascade.CascadeSweepService

Called immediately before a reindex cycle begins so that stale observations from a prior aborted or successful cycle do not leak into the new one.

CONTENT_WRITER - Enum constant in enum class org.alfresco.elasticsearch.batchindexing.model.DeadLetterDocument.FailureStage

Emitted directly by ContentTransformDirectWriter when the ACS transform endpoint returns a non-retryable error (e.g.

contentTransformClient() - Method in class org.alfresco.elasticsearch.batchindexing.domain.transform.ContentTransformConfig

ContentTransformClient - Class in org.alfresco.elasticsearch.batchindexing.domain.transform

ContentTransformClient() - Constructor for class org.alfresco.elasticsearch.batchindexing.domain.transform.ContentTransformClient

ContentTransformConfig - Class in org.alfresco.elasticsearch.batchindexing.domain.transform

Configuration for Transform Core AIO direct integration.

ContentTransformConfig(ContentTransformProperties) - Constructor for class org.alfresco.elasticsearch.batchindexing.domain.transform.ContentTransformConfig

contentTransformDirectWriter(ContentTransformSupportService, ContentTransformClient, ElasticsearchContentModifyPort, ChunkWriteMetricsAccumulator, String, int, ObjectProvider<ContentTransformFailureListener>) - Method in class org.alfresco.elasticsearch.batchindexing.config.BatchIndexingBatchConfig

ContentTransformDirectWriter - Class in org.alfresco.elasticsearch.batchindexing.writers

ContentTransformDirectWriter(ContentTransformSupportService, ContentTransformClient, ElasticsearchContentModifyPort, String) - Constructor for class org.alfresco.elasticsearch.batchindexing.writers.ContentTransformDirectWriter

ContentTransformDirectWriter(ContentTransformSupportService, ContentTransformClient, ElasticsearchContentModifyPort, String, int, ContentTransformFailureListener) - Constructor for class org.alfresco.elasticsearch.batchindexing.writers.ContentTransformDirectWriter

ContentTransformDirectWriter(ContentTransformSupportService, ContentTransformClient, ElasticsearchContentModifyPort, String, int, ChunkWriteMetricsAccumulator, ContentTransformFailureListener) - Constructor for class org.alfresco.elasticsearch.batchindexing.writers.ContentTransformDirectWriter

ContentTransformFailure - Record Class in org.alfresco.elasticsearch.batchindexing.domain.transform

Structured, non-retryable content-transform failure surfaced by ContentTransformClient so the writer can hand it to the DLQ bridge without re-inspecting the underlying HTTP exception.

ContentTransformFailure(String, String) - Constructor for record class org.alfresco.elasticsearch.batchindexing.domain.transform.ContentTransformFailure

Creates an instance of a ContentTransformFailure record class.

ContentTransformFailureListener - Interface in org.alfresco.elasticsearch.batchindexing.writers

Hook invoked by ContentTransformDirectWriter when a per-node content transform fails in a non-retryable way (currently 4xx from ACS).

ContentTransformProperties - Class in org.alfresco.elasticsearch.batchindexing.domain.transform

ContentTransformProperties() - Constructor for class org.alfresco.elasticsearch.batchindexing.domain.transform.ContentTransformProperties

ContentTransformResult - Record Class in org.alfresco.elasticsearch.batchindexing.domain.transform

Outcome of a single ContentTransformClient.transformContent(Long) call.

ContentTransformResult(Optional<String>, Optional<ContentTransformFailure>) - Constructor for record class org.alfresco.elasticsearch.batchindexing.domain.transform.ContentTransformResult

Creates an instance of a ContentTransformResult record class.

ContinuousReindexingConfig - Class in org.alfresco.elasticsearch.batchindexing.config

Configuration for continuous reindexing mode — always active in the batch-indexing module.

ContinuousReindexingConfig() - Constructor for class org.alfresco.elasticsearch.batchindexing.config.ContinuousReindexingConfig

ContinuousReindexingProperties - Class in org.alfresco.elasticsearch.batchindexing.config

Configuration properties for continuous reindexing mode (live indexing via polling).

ContinuousReindexingProperties() - Constructor for class org.alfresco.elasticsearch.batchindexing.config.ContinuousReindexingProperties

continuousReindexingService(JobLauncher, Job, ElasticsearchWatermarkStore, ContinuousReindexingProperties, CascadeSweepService) - Method in class org.alfresco.elasticsearch.batchindexing.config.ContinuousReindexingConfig

ContinuousReindexingService - Class in org.alfresco.elasticsearch.batchindexing

Continuously polls the Alfresco DB for new/changed nodes and launches reindexByDate Spring Batch jobs one at a time.

ContinuousReindexingService(JobLauncher, Job, ElasticsearchWatermarkStore, ContinuousReindexingProperties, Runnable, CascadeSweepService) - Constructor for class org.alfresco.elasticsearch.batchindexing.ContinuousReindexingService

CURRENT_SCHEMA_VERSION - Static variable in class org.alfresco.elasticsearch.batchindexing.model.DeadLetterDocument

Bump when the document structure changes so readers can migrate or reject incompatible documents.

CURRENT_SCHEMA_VERSION - Static variable in class org.alfresco.elasticsearch.batchindexing.model.WatermarkDocument

Monotonically increasing integer.

D

DeadLetterConfig - Class in org.alfresco.elasticsearch.batchindexing.config

Wires the dead-letter queue components.

DeadLetterConfig() - Constructor for class org.alfresco.elasticsearch.batchindexing.config.DeadLetterConfig

DeadLetterDocument - Class in org.alfresco.elasticsearch.batchindexing.model

One record per give-up event the indexer has surfaced for operator visibility.

DeadLetterDocument() - Constructor for class org.alfresco.elasticsearch.batchindexing.model.DeadLetterDocument

DeadLetterDocument.FailureStage - Enum Class in org.alfresco.elasticsearch.batchindexing.model

Stage of the pipeline that produced the skip event.

DeadLetterProperties - Class in org.alfresco.elasticsearch.batchindexing.config

Configuration properties for the dead-letter queue that records poison nodes the indexer has given up on.

DeadLetterProperties() - Constructor for class org.alfresco.elasticsearch.batchindexing.config.DeadLetterProperties

deletedCategoryPaths() - Method in record class org.alfresco.elasticsearch.batchindexing.cascade.CategoryDeleteCascadeSource

Returns the value of the deletedCategoryPaths record component.

deletedCategoryUnprefixedPaths() - Method in record class org.alfresco.elasticsearch.batchindexing.cascade.CategoryDeleteCascadeSource

Returns the value of the deletedCategoryUnprefixedPaths record component.

descendantUuid() - Method in record class org.alfresco.elasticsearch.batchindexing.cascade.CategoryDeleteCascadeSource

Returns the value of the descendantUuid record component.

descendantUuid() - Method in record class org.alfresco.elasticsearch.batchindexing.cascade.RenameCascadeSource

Returns the value of the descendantUuid record component.

destroy() - Method in class org.alfresco.elasticsearch.batchindexing.ContinuousReindexingService

Shuts down the executor permanently.

dlqBulkItemFailureListener(DlqWriter) - Method in class org.alfresco.elasticsearch.batchindexing.config.DeadLetterConfig

DlqBulkItemFailureListener - Class in org.alfresco.elasticsearch.batchindexing.listeners

Bridges per-item bulk failures from the metadata writer into DlqWriter.

DlqBulkItemFailureListener(DlqWriter) - Constructor for class org.alfresco.elasticsearch.batchindexing.listeners.DlqBulkItemFailureListener

dlqContentTransformFailureListener(DlqWriter) - Method in class org.alfresco.elasticsearch.batchindexing.config.DeadLetterConfig

DlqContentTransformFailureListener - Class in org.alfresco.elasticsearch.batchindexing.listeners

Bridges non-retryable content-transform failures (currently ACS 4xx) into DlqWriter.

DlqContentTransformFailureListener(DlqWriter) - Constructor for class org.alfresco.elasticsearch.batchindexing.listeners.DlqContentTransformFailureListener

dlqPageReadFailureListener(DlqWriter) - Method in class org.alfresco.elasticsearch.batchindexing.config.DeadLetterConfig

DlqPageReadFailureListener - Class in org.alfresco.elasticsearch.batchindexing.listeners

Bridges page-level read failures (a bad row in a JDBC page fails the whole page — see reindexing AbstractAlfrescoNodeReader) into DlqWriter as a READER record keyed by the failed time window.

DlqPageReadFailureListener(DlqWriter) - Constructor for class org.alfresco.elasticsearch.batchindexing.listeners.DlqPageReadFailureListener

dlqPathBulkItemFailureListener(DlqWriter) - Method in class org.alfresco.elasticsearch.batchindexing.config.DeadLetterConfig

DlqPathBulkItemFailureListener - Class in org.alfresco.elasticsearch.batchindexing.listeners

Bridges per-item bulk failures from the path writer into DlqWriter.

DlqPathBulkItemFailureListener(DlqWriter) - Constructor for class org.alfresco.elasticsearch.batchindexing.listeners.DlqPathBulkItemFailureListener

dlqSkipListener(DlqWriter) - Method in class org.alfresco.elasticsearch.batchindexing.config.DeadLetterConfig

DlqSkipListener - Class in org.alfresco.elasticsearch.batchindexing.listeners

Bridges Spring Batch skip events into DlqWriter.

DlqSkipListener(DlqWriter) - Constructor for class org.alfresco.elasticsearch.batchindexing.listeners.DlqSkipListener

dlqWriter(OpenSearchClient, DeadLetterProperties) - Method in class org.alfresco.elasticsearch.batchindexing.config.DeadLetterConfig

DlqWriter - Class in org.alfresco.elasticsearch.batchindexing

Writes dead-letter records to a dedicated Elasticsearch index.

DlqWriter(OpenSearchClient, String) - Constructor for class org.alfresco.elasticsearch.batchindexing.DlqWriter

drain() - Method in class org.alfresco.elasticsearch.batchindexing.cascade.CascadeSourceStash

Atomically empties the stash and returns everything observed since the last call.

E

elasticsearchWatermarkStore(OpenSearchClient, ContinuousReindexingProperties) - Method in class org.alfresco.elasticsearch.batchindexing.config.ContinuousReindexingConfig

ElasticsearchWatermarkStore - Class in org.alfresco.elasticsearch.batchindexing

Persists the reindexing watermark as a typed WatermarkDocument in a dedicated Elasticsearch index.

ElasticsearchWatermarkStore(OpenSearchClient, String, int, long) - Constructor for class org.alfresco.elasticsearch.batchindexing.ElasticsearchWatermarkStore

empty() - Static method in record class org.alfresco.elasticsearch.batchindexing.domain.transform.ContentTransformResult

ensureIndexExists() - Method in class org.alfresco.elasticsearch.batchindexing.DlqWriter

Best-effort index creation on startup.

ensureIndexExists() - Method in class org.alfresco.elasticsearch.batchindexing.ElasticsearchWatermarkStore

Ensures the watermark index exists.

equals(Object) - Method in record class org.alfresco.elasticsearch.batchindexing.cascade.CascadeSourceBatch

Indicates whether some other object is "equal to" this one.

equals(Object) - Method in record class org.alfresco.elasticsearch.batchindexing.cascade.CategoryDeleteCascadeSource

Indicates whether some other object is "equal to" this one.

equals(Object) - Method in record class org.alfresco.elasticsearch.batchindexing.cascade.RenameCascadeSource

Indicates whether some other object is "equal to" this one.

equals(Object) - Method in record class org.alfresco.elasticsearch.batchindexing.cascade.SourceDocLookup.SourceDocSnapshot

Indicates whether some other object is "equal to" this one.

equals(Object) - Method in record class org.alfresco.elasticsearch.batchindexing.domain.transform.ContentTransformFailure

Indicates whether some other object is "equal to" this one.

equals(Object) - Method in record class org.alfresco.elasticsearch.batchindexing.domain.transform.ContentTransformResult

Indicates whether some other object is "equal to" this one.

F

failure() - Method in record class org.alfresco.elasticsearch.batchindexing.domain.transform.ContentTransformResult

Returns the value of the failure record component.

failureReason() - Method in record class org.alfresco.elasticsearch.batchindexing.domain.transform.ContentTransformFailure

Returns the value of the failureReason record component.

failureType() - Method in record class org.alfresco.elasticsearch.batchindexing.domain.transform.ContentTransformFailure

Returns the value of the failureType record component.

G

getPhase() - Method in class org.alfresco.elasticsearch.batchindexing.ContinuousReindexingService

H

hashCode() - Method in record class org.alfresco.elasticsearch.batchindexing.cascade.CascadeSourceBatch

Returns a hash code value for this object.

hashCode() - Method in record class org.alfresco.elasticsearch.batchindexing.cascade.CategoryDeleteCascadeSource

Returns a hash code value for this object.

hashCode() - Method in record class org.alfresco.elasticsearch.batchindexing.cascade.RenameCascadeSource

Returns a hash code value for this object.

hashCode() - Method in record class org.alfresco.elasticsearch.batchindexing.cascade.SourceDocLookup.SourceDocSnapshot

Returns a hash code value for this object.

hashCode() - Method in record class org.alfresco.elasticsearch.batchindexing.domain.transform.ContentTransformFailure

Returns a hash code value for this object.

hashCode() - Method in record class org.alfresco.elasticsearch.batchindexing.domain.transform.ContentTransformResult

Returns a hash code value for this object.

I

indexExists() - Method in class org.alfresco.elasticsearch.batchindexing.ElasticsearchWatermarkStore

Best-effort check whether the state index currently exists in the cluster.

isAutoStartup() - Method in class org.alfresco.elasticsearch.batchindexing.ContinuousReindexingService

isEmpty() - Method in record class org.alfresco.elasticsearch.batchindexing.cascade.CascadeSourceBatch

isNoop() - Method in record class org.alfresco.elasticsearch.batchindexing.cascade.RenameCascadeSource

True when the rename didn't actually change the name.

isRunning() - Method in class org.alfresco.elasticsearch.batchindexing.ContinuousReindexingService

J

JobListenerInjector - Class in org.alfresco.elasticsearch.batchindexing.config

Attaches the CacheInvalidationListener to the reindexByDateJob bean (defined in the reindexing module) without overriding it.

JobListenerInjector(CacheInvalidationListener) - Constructor for class org.alfresco.elasticsearch.batchindexing.config.JobListenerInjector

L

lookup(Collection<String>) - Method in class org.alfresco.elasticsearch.batchindexing.cascade.SourceDocLookup

Batched mget by node ref.

M

main(String[]) - Static method in class org.alfresco.elasticsearch.batchindexing.BatchIndexingApp

METADATA_WRITER - Enum constant in enum class org.alfresco.elasticsearch.batchindexing.model.DeadLetterDocument.FailureStage

SkipListener.onSkipInWrite(S, java.lang.Throwable).

N

newPrefixedSegment() - Method in record class org.alfresco.elasticsearch.batchindexing.cascade.RenameCascadeSource

Returns the value of the newPrefixedSegment record component.

newUnprefixedSegment() - Method in record class org.alfresco.elasticsearch.batchindexing.cascade.RenameCascadeSource

Returns the value of the newUnprefixedSegment record component.

nodeRef() - Method in record class org.alfresco.elasticsearch.batchindexing.cascade.CategoryDeleteCascadeSource

Returns the value of the nodeRef record component.

nodeRef() - Method in record class org.alfresco.elasticsearch.batchindexing.cascade.RenameCascadeSource

Returns the value of the nodeRef record component.

O

ofFailure(ContentTransformFailure) - Static method in record class org.alfresco.elasticsearch.batchindexing.domain.transform.ContentTransformResult

ofText(String) - Static method in record class org.alfresco.elasticsearch.batchindexing.domain.transform.ContentTransformResult

oldPrefixedSegment() - Method in record class org.alfresco.elasticsearch.batchindexing.cascade.RenameCascadeSource

Returns the value of the oldPrefixedSegment record component.

oldUnprefixedSegment() - Method in record class org.alfresco.elasticsearch.batchindexing.cascade.RenameCascadeSource

Returns the value of the oldUnprefixedSegment record component.

onBulkItemFailure(Long, String, Long, String, String) - Method in class org.alfresco.elasticsearch.batchindexing.listeners.DlqBulkItemFailureListener

onContentTransformFailure(Long, String, Long, String, String) - Method in class org.alfresco.elasticsearch.batchindexing.listeners.DlqContentTransformFailureListener

onContentTransformFailure(Long, String, Long, String, String) - Method in interface org.alfresco.elasticsearch.batchindexing.writers.ContentTransformFailureListener

onPageReadFailure(String, NodeParams, Throwable) - Method in class org.alfresco.elasticsearch.batchindexing.listeners.DlqPageReadFailureListener

onPathBulkItemFailure(Long, String, Long, String, String) - Method in class org.alfresco.elasticsearch.batchindexing.listeners.DlqPathBulkItemFailureListener

onSkipInProcess(AlfrescoNode, Throwable) - Method in class org.alfresco.elasticsearch.batchindexing.listeners.DlqSkipListener

onSkipInRead(Throwable) - Method in class org.alfresco.elasticsearch.batchindexing.listeners.DlqSkipListener

onSkipInWrite(ReindexingEvent, Throwable) - Method in class org.alfresco.elasticsearch.batchindexing.listeners.DlqSkipListener

org.alfresco.elasticsearch.batchindexing - package org.alfresco.elasticsearch.batchindexing

org.alfresco.elasticsearch.batchindexing.cascade - package org.alfresco.elasticsearch.batchindexing.cascade

org.alfresco.elasticsearch.batchindexing.config - package org.alfresco.elasticsearch.batchindexing.config

org.alfresco.elasticsearch.batchindexing.domain.transform - package org.alfresco.elasticsearch.batchindexing.domain.transform

org.alfresco.elasticsearch.batchindexing.listeners - package org.alfresco.elasticsearch.batchindexing.listeners

org.alfresco.elasticsearch.batchindexing.model - package org.alfresco.elasticsearch.batchindexing.model

org.alfresco.elasticsearch.batchindexing.writers - package org.alfresco.elasticsearch.batchindexing.writers

P

PATH_WRITER - Enum constant in enum class org.alfresco.elasticsearch.batchindexing.model.DeadLetterDocument.FailureStage

Emitted directly by ElasticsearchPathWriter after its internal retry loop; never fires through Spring Batch skip.

paths() - Method in record class org.alfresco.elasticsearch.batchindexing.cascade.SourceDocLookup.SourceDocSnapshot

Returns the value of the paths record component.

postProcessAfterInitialization(Object, String) - Method in class org.alfresco.elasticsearch.batchindexing.config.JobListenerInjector

prefixedSegment() - Method in record class org.alfresco.elasticsearch.batchindexing.cascade.SourceDocLookup.SourceDocSnapshot

Returns the value of the prefixedSegment record component.

PROCESSOR - Enum constant in enum class org.alfresco.elasticsearch.batchindexing.model.DeadLetterDocument.FailureStage

SkipListener.onSkipInProcess(T, java.lang.Throwable).

R

read() - Method in class org.alfresco.elasticsearch.batchindexing.ElasticsearchWatermarkStore

Reads the full watermark document from Elasticsearch.

READER - Enum constant in enum class org.alfresco.elasticsearch.batchindexing.model.DeadLetterDocument.FailureStage

Reader-side failure.

recordCategoryDelete(CategoryDeleteCascadeSource) - Method in class org.alfresco.elasticsearch.batchindexing.cascade.CascadeSourceStash

recordRename(RenameCascadeSource) - Method in class org.alfresco.elasticsearch.batchindexing.cascade.CascadeSourceStash

recordSkip(Long, String, Long, DeadLetterDocument.FailureStage, String, String) - Method in class org.alfresco.elasticsearch.batchindexing.DlqWriter

Same as DlqWriter.recordSkip(Long, String, Long, FailureStage, Throwable) but with the failure classifier / reason supplied as strings.

recordSkip(Long, String, Long, DeadLetterDocument.FailureStage, Throwable) - Method in class org.alfresco.elasticsearch.batchindexing.DlqWriter

Record a give-up event for dbId.

recordWindowFailure(long, long, Throwable) - Method in class org.alfresco.elasticsearch.batchindexing.DlqWriter

Record a page-level read failure keyed by the failed time window.

renameCascadeService(OpenSearchClient, ElasticsearchProperties, CascadeProperties) - Method in class org.alfresco.elasticsearch.batchindexing.config.CascadeConfig

RenameCascadeService - Class in org.alfresco.elasticsearch.batchindexing.cascade

Cascades a rename to descendants by swapping the old path segment for the new one in each descendant's PATH / UNPREFIXED_PATH arrays.

RenameCascadeService(OpenSearchClient, ElasticsearchProperties, CascadeProperties) - Constructor for class org.alfresco.elasticsearch.batchindexing.cascade.RenameCascadeService

RenameCascadeSource - Record Class in org.alfresco.elasticsearch.batchindexing.cascade

Descriptor for a rename cascade: the old and new terminal path segments to swap in descendants' PATH / UNPREFIXED_PATH arrays.

RenameCascadeSource(String, String, String, String, String, String) - Constructor for record class org.alfresco.elasticsearch.batchindexing.cascade.RenameCascadeSource

Creates an instance of a RenameCascadeSource record class.

renameCount() - Method in class org.alfresco.elasticsearch.batchindexing.cascade.CascadeSourceStash

renames() - Method in record class org.alfresco.elasticsearch.batchindexing.cascade.CascadeSourceBatch

Returns the value of the renames record component.

run(ApplicationArguments) - Method in class org.alfresco.elasticsearch.batchindexing.BatchIndexingApp

S

shutdown() - Method in class org.alfresco.elasticsearch.batchindexing.writers.ContentTransformDirectWriter

SourceDocLookup - Class in org.alfresco.elasticsearch.batchindexing.cascade

Batched mget helper that snapshots cascade-relevant fields (PATH, UNPREFIXED_PATH, TYPE) from source docs before the downstream writers overwrite them.

SourceDocLookup(OpenSearchClient, ElasticsearchProperties) - Constructor for class org.alfresco.elasticsearch.batchindexing.cascade.SourceDocLookup

SourceDocLookup.SourceDocSnapshot - Record Class in org.alfresco.elasticsearch.batchindexing.cascade

Snapshot of a source doc's cascade-relevant fields.

SourceDocSnapshot(String, String, String, List<String>, List<String>) - Constructor for record class org.alfresco.elasticsearch.batchindexing.cascade.SourceDocLookup.SourceDocSnapshot

Creates an instance of a SourceDocSnapshot record class.

start() - Method in class org.alfresco.elasticsearch.batchindexing.ContinuousReindexingService

stop() - Method in class org.alfresco.elasticsearch.batchindexing.ContinuousReindexingService

stop(Runnable) - Method in class org.alfresco.elasticsearch.batchindexing.ContinuousReindexingService

sweep() - Method in class org.alfresco.elasticsearch.batchindexing.cascade.CascadeSweepService

Called only after a reindex cycle completes with BatchStatus.COMPLETED.

T

TERMINATE_JVM_ON_LOCK_CONFLICT - Static variable in class org.alfresco.elasticsearch.batchindexing.ContinuousReindexingService

text() - Method in record class org.alfresco.elasticsearch.batchindexing.domain.transform.ContentTransformResult

Returns the value of the text record component.

toString() - Method in record class org.alfresco.elasticsearch.batchindexing.cascade.CascadeSourceBatch

Returns a string representation of this record class.

toString() - Method in record class org.alfresco.elasticsearch.batchindexing.cascade.CategoryDeleteCascadeSource

Returns a string representation of this record class.

toString() - Method in record class org.alfresco.elasticsearch.batchindexing.cascade.RenameCascadeSource

Returns a string representation of this record class.

toString() - Method in record class org.alfresco.elasticsearch.batchindexing.cascade.SourceDocLookup.SourceDocSnapshot

Returns a string representation of this record class.

toString() - Method in record class org.alfresco.elasticsearch.batchindexing.domain.transform.ContentTransformFailure

Returns a string representation of this record class.

toString() - Method in record class org.alfresco.elasticsearch.batchindexing.domain.transform.ContentTransformResult

Returns a string representation of this record class.

totalSize() - Method in record class org.alfresco.elasticsearch.batchindexing.cascade.CascadeSourceBatch

transformContent(Long) - Method in class org.alfresco.elasticsearch.batchindexing.domain.transform.ContentTransformClient

Fetch transformed content for the given node.

type() - Method in record class org.alfresco.elasticsearch.batchindexing.cascade.SourceDocLookup.SourceDocSnapshot

Returns the value of the type record component.

U

unprefixedPaths() - Method in record class org.alfresco.elasticsearch.batchindexing.cascade.SourceDocLookup.SourceDocSnapshot

Returns the value of the unprefixedPaths record component.

unprefixedSegment() - Method in record class org.alfresco.elasticsearch.batchindexing.cascade.SourceDocLookup.SourceDocSnapshot

Returns the value of the unprefixedSegment record component.

V

validate() - Method in class org.alfresco.elasticsearch.batchindexing.config.ContinuousReindexingProperties

valueOf(String) - Static method in enum class org.alfresco.elasticsearch.batchindexing.model.DeadLetterDocument.FailureStage

Returns the enum constant of this class with the specified name.

values() - Static method in enum class org.alfresco.elasticsearch.batchindexing.model.DeadLetterDocument.FailureStage

Returns an array containing the constants of this enum class, in the order they are declared.

W

WatermarkAccessException - Exception in org.alfresco.elasticsearch.batchindexing

Checked exception indicating the watermark store cannot be reached.

WatermarkAccessException(String) - Constructor for exception org.alfresco.elasticsearch.batchindexing.WatermarkAccessException

WatermarkAccessException(String, Throwable) - Constructor for exception org.alfresco.elasticsearch.batchindexing.WatermarkAccessException

WatermarkBootstrap - Class in org.alfresco.elasticsearch.batchindexing

One-shot startup guard and cursor seed for the batch-indexing watermark.

WatermarkBootstrap(ElasticsearchWatermarkStore, OpenSearchClient, ContinuousReindexingProperties) - Constructor for class org.alfresco.elasticsearch.batchindexing.WatermarkBootstrap

WatermarkConflictException - Exception in org.alfresco.elasticsearch.batchindexing

Unchecked exception thrown when a watermark write fails with HTTP 409 (version conflict).

WatermarkConflictException(String, Throwable) - Constructor for exception org.alfresco.elasticsearch.batchindexing.WatermarkConflictException

WatermarkDocument - Class in org.alfresco.elasticsearch.batchindexing.model

Typed watermark document persisted in Elasticsearch.

WatermarkDocument() - Constructor for class org.alfresco.elasticsearch.batchindexing.model.WatermarkDocument

write(WatermarkDocument) - Method in class org.alfresco.elasticsearch.batchindexing.ElasticsearchWatermarkStore

Writes the watermark document after a reindexing cycle.

write(Chunk<? extends ReindexingEvent>) - Method in class org.alfresco.elasticsearch.batchindexing.cascade.CascadeCollectorWriter

write(Chunk<? extends ReindexingEvent>) - Method in class org.alfresco.elasticsearch.batchindexing.writers.ContentTransformDirectWriter

Failures are intentionally caught and logged rather than propagated to Spring Batch.

writer(ElasticsearchReindexProperties, ElasticsearchRepoEventItemWriter, ContentTransformDirectWriter, ElasticsearchPathWriter, CascadeProperties, CascadeCollectorWriter, ChunkWriteMetricsAccumulator) - Method in class org.alfresco.elasticsearch.batchindexing.config.BatchIndexingBatchConfig

A B C D E F G H I J L M N O P R S T U V W
All Classes and Interfaces|All Packages|Constant Field Values|Serialized Form