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

Class IndexingProcessor

java.lang.Object

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

All Implemented Interfaces:

StreamProcessorTopology

public class IndexingProcessor
extends Object
implements StreamProcessorTopology

Since:

2025.0

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	IndexingProcessor.AbstractIndexingComputation
static class	IndexingProcessor.AsynchronousIndexingComputation
static class	IndexingProcessor.SynchronousIndexingComputation

Field Summary

Fields

Modifier and Type	Field	Description
static final String	ASYNC_COMPUTATION_NAME
static final String	STREAM_NAME
static final String	SYNC_COMPUTATION_NAME

Constructor Summary

Constructors

Constructor	Description
IndexingProcessor()

Method Summary

Modifier and Type	Method	Description
Topology	getTopology(Map<String,String> options)	Returns a Stream computation topology.

Methods inherited from class java.lang.Object

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

Field Details

SYNC_COMPUTATION_NAME

public static final String SYNC_COMPUTATION_NAME

See Also:

• Constant Field Values

ASYNC_COMPUTATION_NAME

public static final String ASYNC_COMPUTATION_NAME

See Also:

• Constant Field Values

STREAM_NAME

public static final String STREAM_NAME

See Also:

• Constant Field Values

Constructor Details

IndexingProcessor

public IndexingProcessor()

Method Details

getTopology

public Topology getTopology(Map<String,String> options)

Description copied from interface: StreamProcessorTopology

Returns a Stream computation topology.

Specified by:

getTopology in interface StreamProcessorTopology