Package org.alfresco.elasticsearch.batchindexing.writers

Class ContentTransformDirectWriter

java.lang.Object

org.alfresco.elasticsearch.batchindexing.writers.ContentTransformDirectWriter

All Implemented Interfaces:

org.springframework.batch.infrastructure.item.ItemWriter<org.alfresco.reindexing.model.ReindexingEvent>

public class ContentTransformDirectWriter
extends Object
implements org.springframework.batch.infrastructure.item.ItemWriter<org.alfresco.reindexing.model.ReindexingEvent>

Constructor Summary

Constructors

Constructor	Description
ContentTransformDirectWriter(org.alfresco.reindexing.domain.transform.ContentTransformSupportService contentTransformSupportService, ContentTransformClient contentTransformClient, org.alfresco.indexing.shared.opensearch.ElasticsearchContentModifyPort contentModifyPort, String storeRef)
ContentTransformDirectWriter(org.alfresco.reindexing.domain.transform.ContentTransformSupportService contentTransformSupportService, ContentTransformClient contentTransformClient, org.alfresco.indexing.shared.opensearch.ElasticsearchContentModifyPort contentModifyPort, String storeRef, int maxConcurrency)

Method Summary

Modifier and Type	Method	Description
void	shutdown()
void	write(org.springframework.batch.infrastructure.item.Chunk<? extends org.alfresco.reindexing.model.ReindexingEvent> chunk)	Failures are intentionally caught and logged rather than propagated to Spring Batch.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

ContentTransformDirectWriter

public ContentTransformDirectWriter(org.alfresco.reindexing.domain.transform.ContentTransformSupportService contentTransformSupportService,
 ContentTransformClient contentTransformClient,
 org.alfresco.indexing.shared.opensearch.ElasticsearchContentModifyPort contentModifyPort,
 String storeRef)

ContentTransformDirectWriter

public ContentTransformDirectWriter(org.alfresco.reindexing.domain.transform.ContentTransformSupportService contentTransformSupportService,
 ContentTransformClient contentTransformClient,
 org.alfresco.indexing.shared.opensearch.ElasticsearchContentModifyPort contentModifyPort,
 String storeRef,
 int maxConcurrency)

Method Details

shutdown

@PreDestroy
public void shutdown()

write

public void write(org.springframework.batch.infrastructure.item.Chunk<? extends org.alfresco.reindexing.model.ReindexingEvent> chunk)
           throws Exception

Failures are intentionally caught and logged rather than propagated to Spring Batch. Content transformation is a best-effort secondary indexing step — a failed transform should not cause the entire chunk to be retried or the step to fail, because the metadata and path indexing (handled by other writers) can still succeed. The affected nodes will be retried on the next reindexing window overlap.

Specified by:

write in interface org.springframework.batch.infrastructure.item.ItemWriter<org.alfresco.reindexing.model.ReindexingEvent>

Throws:

Exception