org.alfresco.solr

Class AlfrescoUpdateHandler

java.lang.Object

org.apache.solr.update.UpdateHandler

org.alfresco.solr.AlfrescoUpdateHandler

All Implemented Interfaces:

org.apache.solr.core.SolrInfoMBean

public class AlfrescoUpdateHandler
extends org.apache.solr.update.UpdateHandler

DirectUpdateHandler2 implements an UpdateHandler where documents are added directly to the main Lucene index as opposed to adding to a separate smaller index. For this reason, not all combinations to/from pending and committed are supported. This version supports efficient removal of duplicates on a commit. It works by maintaining a related count for every document being added or deleted. At commit time, for every id with a count, all but the last "count" docs with that id are deleted.

Supported add command parameters:

allowDups	overwritePending	overwriteCommitted	efficiency
false	false	true	fast
true or false	true	true	fast
true	false	false	fastest

Supported delete commands:

command	fromPending	fromCommitted	efficiency
delete	true	true	fast
deleteByQuery	true	true	very slow*

deleteByQuery causes a commit to happen (close current index writer, open new index reader) before it can be processed. If deleteByQuery functionality is needed, it's best if they can be batched and executed together so they may share the same index reader.

Since:

solr 0.9

Version:

$Id: DirectUpdateHandler2.java 824380 2009-10-12 15:18:08Z koji $

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.solr.core.SolrInfoMBean

org.apache.solr.core.SolrInfoMBean.Category

Field Summary

Fields

Modifier and Type	Field and Description
protected Lock	iwAccess
protected Lock	iwCommit
protected static org.slf4j.Logger	log
protected org.alfresco.solr.AlfrescoUpdateHandler.CommitTracker	tracker
protected org.apache.lucene.index.IndexWriter	writer

Fields inherited from class org.apache.solr.update.UpdateHandler

commitCallbacks, core, idField, idFieldType, idTerm, optimizeCallbacks, schema

Constructor Summary

Constructors

Constructor and Description
AlfrescoUpdateHandler(org.apache.solr.core.SolrCore core)

Method Summary

Methods

Modifier and Type	Method and Description
int	addDoc(org.apache.solr.update.AddUpdateCommand cmd)
void	close()
protected void	closeWriter()
void	commit(org.apache.solr.update.CommitUpdateCommand cmd)
void	delete(org.apache.solr.update.DeleteUpdateCommand cmd)
void	deleteByQuery(org.apache.solr.update.DeleteUpdateCommand cmd)
void	forceOpenWriter()
org.apache.solr.core.SolrInfoMBean.Category	getCategory()
String	getDescription()
URL[]	getDocs()
String	getName()
String	getSource()
String	getSourceId()
org.apache.solr.common.util.NamedList	getStatistics()
String	getVersion()
int	mergeIndexes(org.apache.solr.update.MergeIndexesCommand cmd)
protected void	openWriter()
void	rollback(org.apache.solr.update.RollbackUpdateCommand cmd)
protected void	rollbackWriter()
String	toString()

Methods inherited from class org.apache.solr.update.UpdateHandler

callPostCommitCallbacks, callPostOptimizeCallbacks, createMainIndexWriter, getIndexedId, getIndexedIdOptional, idTerm, registerCommitCallback, registerOptimizeCallback

Methods inherited from class java.lang.Object

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

Field Detail

log

protected static final org.slf4j.Logger log

tracker

protected final org.alfresco.solr.AlfrescoUpdateHandler.CommitTracker tracker

iwAccess

protected final Lock iwAccess

iwCommit

protected final Lock iwCommit

writer

protected org.apache.lucene.index.IndexWriter writer

Constructor Detail

AlfrescoUpdateHandler

public AlfrescoUpdateHandler(org.apache.solr.core.SolrCore core)
                      throws IOException

Throws:

IOException

Method Detail

openWriter

protected void openWriter()
                   throws IOException

Throws:

IOException

closeWriter

protected void closeWriter()
                    throws IOException

Throws:

IOException

rollbackWriter

protected void rollbackWriter()
                       throws IOException

Throws:

IOException

addDoc

public int addDoc(org.apache.solr.update.AddUpdateCommand cmd)
           throws IOException

Specified by:

addDoc in class org.apache.solr.update.UpdateHandler

Throws:

IOException

delete

public void delete(org.apache.solr.update.DeleteUpdateCommand cmd)
            throws IOException

Specified by:

delete in class org.apache.solr.update.UpdateHandler

Throws:

IOException

deleteByQuery

public void deleteByQuery(org.apache.solr.update.DeleteUpdateCommand cmd)
                   throws IOException

Specified by:

deleteByQuery in class org.apache.solr.update.UpdateHandler

Throws:

IOException

mergeIndexes

public int mergeIndexes(org.apache.solr.update.MergeIndexesCommand cmd)
                 throws IOException

Specified by:

mergeIndexes in class org.apache.solr.update.UpdateHandler

Throws:

IOException

forceOpenWriter

public void forceOpenWriter()
                     throws IOException

Throws:

IOException

commit

public void commit(org.apache.solr.update.CommitUpdateCommand cmd)
            throws IOException

Specified by:

commit in class org.apache.solr.update.UpdateHandler

Throws:

IOException

rollback

public void rollback(org.apache.solr.update.RollbackUpdateCommand cmd)
              throws IOException

Specified by:

rollback in class org.apache.solr.update.UpdateHandler

Throws:

IOException

Since:

Solr 1.4

close

public void close()
           throws IOException

Specified by:

close in class org.apache.solr.update.UpdateHandler

Throws:

IOException

getName

public String getName()

getVersion

public String getVersion()

getDescription

public String getDescription()

getCategory

public org.apache.solr.core.SolrInfoMBean.Category getCategory()

getSourceId

public String getSourceId()

getSource

public String getSource()

getDocs

public URL[] getDocs()

getStatistics

public org.apache.solr.common.util.NamedList getStatistics()

toString

public String toString()

Overrides:

toString in class Object