com.atlassian.confluence.search.lucene

Class LuceneIncrementalIndexManager

java.lang.Object

com.atlassian.confluence.search.lucene.LuceneIncrementalIndexManager

All Implemented Interfaces:

IncrementalIndexManager

@LuceneIndependent
 @Internal
public class LuceneIncrementalIndexManager
extends Object
implements IncrementalIndexManager

Entry point to the majority of the Lucene indexing subsystem.

Since:

7.9.0

Field Summary

Fields

Modifier and Type	Field and Description
protected static int	CLEAR_SESSION_BATCH_SIZE How many index tasks to process before clearing the L1 hibernate cache.
static String	QUEUE_BATCH_SIZE_KEY

Constructor Summary

Constructors

Constructor and Description
LuceneIncrementalIndexManager(IndexLockService lockService, IndexTaskQueue<ConfluenceIndexTask> taskQueue, SearchIndexAccessor searchIndexAccessor, com.atlassian.event.api.EventPublisher eventPublisher, FullReindexManager fullReindexManager, SearchIndex targetIndex, org.hibernate.SessionFactory sessionFactory, HibernateSessionManager5 sessionManager, JournalService journalService)

Method Summary

Modifier and Type	Method and Description
void	addTask(ConfluenceIndexTask task) Adds a new task to the index queue
boolean	flushQueue(IndexManager.IndexQueueFlushMode flushMode) Flushes the index queue, processing a batch of the tasks
FlushStatistics	getLastNonEmptyFlushStats()
int	getQueueSize()
boolean	isFlushing() Returns true if the the index queue is currently being flushed.
void	resetIndexQueue() Delete all of the entries on the index queue.

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.atlassian.confluence.search.lucene.IncrementalIndexManager

flushQueue

Field Detail

QUEUE_BATCH_SIZE_KEY

public static final String QUEUE_BATCH_SIZE_KEY

See Also:

Constant Field Values

CLEAR_SESSION_BATCH_SIZE

protected static final int CLEAR_SESSION_BATCH_SIZE

How many index tasks to process before clearing the L1 hibernate cache.

See Also:

Constant Field Values

Constructor Detail

LuceneIncrementalIndexManager

public LuceneIncrementalIndexManager(IndexLockService lockService,
                                     IndexTaskQueue<ConfluenceIndexTask> taskQueue,
                                     SearchIndexAccessor searchIndexAccessor,
                                     com.atlassian.event.api.EventPublisher eventPublisher,
                                     FullReindexManager fullReindexManager,
                                     SearchIndex targetIndex,
                                     org.hibernate.SessionFactory sessionFactory,
                                     HibernateSessionManager5 sessionManager,
                                     JournalService journalService)

Method Detail

isFlushing

@Transactional(readOnly=true,
               propagation=SUPPORTS)
public boolean isFlushing()

Description copied from interface: IncrementalIndexManager

Returns true if the the index queue is currently being flushed.

Specified by:

isFlushing in interface IncrementalIndexManager

Returns:

true if flushing, false otherwise.

flushQueue

@Transactional(readOnly=true,
               propagation=REQUIRED)
public boolean flushQueue(IndexManager.IndexQueueFlushMode flushMode)

Description copied from interface: IncrementalIndexManager

Flushes the index queue, processing a batch of the tasks

Specified by:

flushQueue in interface IncrementalIndexManager

Parameters:

flushMode - - whether to flush the entire queue, or just one batch of batchsize as specified by the system property index.queue.batch.size

Returns:

whether the flush actually took place

resetIndexQueue

@Transactional(propagation=REQUIRED)
public void resetIndexQueue()

Delete all of the entries on the index queue. This should NOT be called during the normal running of Confluence since all pending Index Tasks will be deleted WITHOUT being processed.

Specified by:

resetIndexQueue in interface IncrementalIndexManager

getLastNonEmptyFlushStats

@Transactional(readOnly=true,
               propagation=SUPPORTS)
public FlushStatistics getLastNonEmptyFlushStats()

Specified by:

getLastNonEmptyFlushStats in interface IncrementalIndexManager

Returns:

the information about last queue flush. null if no flush has occured from system start.

getQueueSize

@Transactional(readOnly=true,
               propagation=SUPPORTS)
public int getQueueSize()

Specified by:

getQueueSize in interface IncrementalIndexManager

Returns:

the number of pending items in the corresponding index queue

addTask

@Transactional(propagation=REQUIRED)
public void addTask(ConfluenceIndexTask task)

Description copied from interface: IncrementalIndexManager

Adds a new task to the index queue

Specified by:

addTask in interface IncrementalIndexManager