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

Class IndexingProcessor.AbstractIndexingComputation

java.lang.Object

org.nuxeo.lib.stream.computation.AbstractComputation

org.nuxeo.lib.stream.computation.AbstractBatchComputation

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

All Implemented Interfaces:

Computation

Direct Known Subclasses:

IndexingProcessor.AsynchronousIndexingComputation, IndexingProcessor.SynchronousIndexingComputation

Enclosing class:

IndexingProcessor

public abstract static class IndexingProcessor.AbstractIndexingComputation
extends AbstractBatchComputation

Field Summary

Fields

Modifier and Type	Field	Description
protected final Codec<IndexingDomainEvent>	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
AbstractIndexingComputation(String name)

Method Summary

Modifier and Type	Method	Description
protected int	indexSimpleEvents(String repository, List<IndexingDomainEvent> allEvents, boolean refresh)
protected int	indexSimpleEvents(List<IndexingDomainEvent> events, boolean refresh)

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

batchFailure, batchProcess, 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

Field Details

codec

protected final Codec<IndexingDomainEvent> codec

Constructor Details

AbstractIndexingComputation

public AbstractIndexingComputation(String name)

Method Details

indexSimpleEvents

protected int indexSimpleEvents(List<IndexingDomainEvent> events,
 boolean refresh)

indexSimpleEvents

protected int indexSimpleEvents(String repository,
 List<IndexingDomainEvent> allEvents,
 boolean refresh)