org.apache.solr.core

Class IndexDeletionPolicyWrapper

java.lang.Object

org.apache.solr.core.IndexDeletionPolicyWrapper

All Implemented Interfaces:

org.apache.lucene.index.IndexDeletionPolicy

public class IndexDeletionPolicyWrapper
extends java.lang.Object
implements org.apache.lucene.index.IndexDeletionPolicy

A wrapper for an IndexDeletionPolicy instance.

Provides features for looking up IndexCommit given a version. Allows reserving index commit points for certain amounts of time to support features such as index replication or snapshooting directly out of a live index directory.

Version:

$Id: IndexDeletionPolicyWrapper.java 1201265 2011-11-12 14:09:28Z mikemccand $

See Also:

IndexDeletionPolicy

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
private class	IndexDeletionPolicyWrapper.IndexCommitWrapper

Field Summary

Fields

Modifier and Type	Field and Description
private org.apache.lucene.index.IndexDeletionPolicy	deletionPolicy
private org.apache.lucene.index.IndexCommit	latestCommit
private java.util.Map<java.lang.Long,java.lang.Long>	reserves
private java.util.concurrent.ConcurrentHashMap<java.lang.Long,java.util.concurrent.atomic.AtomicInteger>	savedCommits
private java.util.Map<java.lang.Long,org.apache.lucene.index.IndexCommit>	solrVersionVsCommits

Constructor Summary

Constructors

Constructor and Description
IndexDeletionPolicyWrapper(org.apache.lucene.index.IndexDeletionPolicy deletionPolicy)

Method Summary

Modifier and Type	Method and Description
private void	cleanReserves()
org.apache.lucene.index.IndexCommit	getCommitPoint(java.lang.Long version)
java.util.Map<java.lang.Long,org.apache.lucene.index.IndexCommit>	getCommits() Gets the commit points for the index.
org.apache.lucene.index.IndexCommit	getLatestCommit() Gets the most recent commit point It is recommended to reserve a commit point for the duration of usage so that it is not deleted by the underlying deletion policy
org.apache.lucene.index.IndexDeletionPolicy	getWrappedDeletionPolicy()
void	onCommit(java.util.List list) Internal use for Lucene...
void	onInit(java.util.List list) Internal use for Lucene...
void	releaseCommitPoint(java.lang.Long indexCommitVersion) Release a previously saved commit point
void	saveCommitPoint(java.lang.Long indexCommitVersion) Permanently prevent this commit point from being deleted.
void	setReserveDuration(java.lang.Long indexVersion, long reserveTime) Set the duration for which commit point is to be reserved by the deletion policy.
private void	updateCommitPoints(java.util.List<IndexDeletionPolicyWrapper.IndexCommitWrapper> list)
private java.util.List<IndexDeletionPolicyWrapper.IndexCommitWrapper>	wrap(java.util.List<org.apache.lucene.index.IndexCommit> list)

Methods inherited from class java.lang.Object

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

Field Detail

deletionPolicy

private final org.apache.lucene.index.IndexDeletionPolicy deletionPolicy

solrVersionVsCommits

private volatile java.util.Map<java.lang.Long,org.apache.lucene.index.IndexCommit> solrVersionVsCommits

reserves

private final java.util.Map<java.lang.Long,java.lang.Long> reserves

latestCommit

private volatile org.apache.lucene.index.IndexCommit latestCommit

savedCommits

private final java.util.concurrent.ConcurrentHashMap<java.lang.Long,java.util.concurrent.atomic.AtomicInteger> savedCommits

Constructor Detail

IndexDeletionPolicyWrapper

public IndexDeletionPolicyWrapper(org.apache.lucene.index.IndexDeletionPolicy deletionPolicy)

Method Detail

getLatestCommit

public org.apache.lucene.index.IndexCommit getLatestCommit()

Gets the most recent commit point

It is recommended to reserve a commit point for the duration of usage so that it is not deleted by the underlying deletion policy

Returns:

the most recent commit point

getWrappedDeletionPolicy

public org.apache.lucene.index.IndexDeletionPolicy getWrappedDeletionPolicy()

setReserveDuration

public void setReserveDuration(java.lang.Long indexVersion,
                               long reserveTime)

Set the duration for which commit point is to be reserved by the deletion policy.

Parameters:

indexVersion - version of the commit point to be reserved

reserveTime - time in milliseconds for which the commit point is to be reserved

cleanReserves

private void cleanReserves()

wrap

private java.util.List<IndexDeletionPolicyWrapper.IndexCommitWrapper> wrap(java.util.List<org.apache.lucene.index.IndexCommit> list)

saveCommitPoint

public void saveCommitPoint(java.lang.Long indexCommitVersion)

Permanently prevent this commit point from being deleted. A counter is used to allow a commit point to be correctly saved and released multiple times.

releaseCommitPoint

public void releaseCommitPoint(java.lang.Long indexCommitVersion)

Release a previously saved commit point

onInit

public void onInit(java.util.List list)
            throws java.io.IOException

Internal use for Lucene... do not explicitly call.

Specified by:

onInit in interface org.apache.lucene.index.IndexDeletionPolicy

Throws:

java.io.IOException

onCommit

public void onCommit(java.util.List list)
              throws java.io.IOException

Internal use for Lucene... do not explicitly call.

Specified by:

onCommit in interface org.apache.lucene.index.IndexDeletionPolicy

Throws:

java.io.IOException

getCommitPoint

public org.apache.lucene.index.IndexCommit getCommitPoint(java.lang.Long version)

Parameters:

version - the version of the commit point

Returns:

a commit point corresponding to the given version

getCommits

public java.util.Map<java.lang.Long,org.apache.lucene.index.IndexCommit> getCommits()

Gets the commit points for the index. This map instance may change between commits and commit points may be deleted. It is recommended to reserve a commit point for the duration of usage

Returns:

a Map of version to commit points

updateCommitPoints

private void updateCommitPoints(java.util.List<IndexDeletionPolicyWrapper.IndexCommitWrapper> list)