Package org.nuxeo.ecm.core.search.index

Class IndexingProcessor.AsynchronousIndexingComputation

java.lang.Object

org.nuxeo.lib.stream.computation.AbstractComputation

org.nuxeo.lib.stream.computation.AbstractBatchComputation

org.nuxeo.ecm.core.search.index.IndexingProcessor.AbstractIndexingComputation

org.nuxeo.ecm.core.search.index.IndexingProcessor.AsynchronousIndexingComputation

All Implemented Interfaces:

Computation

Enclosing class:

IndexingProcessor

public static class IndexingProcessor.AsynchronousIndexingComputation
extends IndexingProcessor.AbstractIndexingComputation

Field Summary

Fields inherited from class org.nuxeo.ecm.core.search.index.IndexingProcessor.AbstractIndexingComputation

codec

Fields inherited from class org.nuxeo.lib.stream.computation.AbstractBatchComputation

batchRecords, currentInputStream, newBatch, removeLastRecordOnRetry, thresholdMillis, TIMER_BATCH

Fields inherited from class org.nuxeo.lib.stream.computation.AbstractComputation

INPUT_1, INPUT_2, INPUT_3, INPUT_NULL, metadata, OUTPUT_1, OUTPUT_2, OUTPUT_3, OUTPUT_4

Constructor Summary

Constructors

Constructor	Description
AsynchronousIndexingComputation(String name)

Method Summary

Modifier and Type	Method	Description
void	batchFailure(ComputationContext context, String inputStreamName, List<Record> records)	Called when the retry policy has failed.
protected void	batchProcess(ComputationContext context, String inputStreamName, List<Record> records)	Called when: the batch capacity is reached the time threshold is reached the inputStreamName has changed If this method raises an exception the retry policy is applied.

Methods inherited from class org.nuxeo.ecm.core.search.index.IndexingProcessor.AbstractIndexingComputation

indexSimpleEvents, indexSimpleEvents

Methods inherited from class org.nuxeo.lib.stream.computation.AbstractBatchComputation

checkpointBatch, init, processFailure, processRecord, processRetry, processTimer

Methods inherited from class org.nuxeo.lib.stream.computation.AbstractComputation

metadata

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.nuxeo.lib.stream.computation.Computation

destroy, signalStop

Constructor Details

AsynchronousIndexingComputation

public AsynchronousIndexingComputation(String name)

Method Details

batchProcess

protected void batchProcess(ComputationContext context,
 String inputStreamName,
 List<Record> records)

Description copied from class: AbstractBatchComputation

Called when:

• the batch capacity is reached
• the time threshold is reached
• the inputStreamName has changed

If this method raises an exception the retry policy is applied.

Specified by:

batchProcess in class AbstractBatchComputation

Parameters:

context - used to send records to output streams, note that the checkpoint is managed automatically.

inputStreamName - the input streams where the records are coming from

records - the batch of records

batchFailure

public void batchFailure(ComputationContext context,
 String inputStreamName,
 List<Record> records)

Description copied from class: AbstractBatchComputation

Called when the retry policy has failed.

Specified by:

batchFailure in class AbstractBatchComputation