|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.compass.core.lucene.engine.transaction.support.AbstractTransactionProcessor
org.compass.core.lucene.engine.transaction.support.AbstractSearchTransactionProcessor
org.compass.core.lucene.engine.transaction.support.AbstractConcurrentTransactionProcessor
org.compass.core.lucene.engine.transaction.lucene.LuceneTransactionProcessor
public class LuceneTransactionProcessor
Lucene based transaction, allows to perfom dirty operations directly over the index using Lucene support for transactions. Reads and search will be performed on the index itself without taking into account any transactional operations.
Field Summary |
---|
Fields inherited from class org.compass.core.lucene.engine.transaction.support.AbstractTransactionProcessor |
---|
indexManager, mapping, searchEngine, searchEngineFactory |
Constructor Summary | |
---|---|
LuceneTransactionProcessor(LuceneSearchEngine searchEngine)
|
Method Summary | |
---|---|
protected void |
doCommit(boolean onePhase)
Sub classes should implement this. |
protected LuceneSearchEngineHits |
doFind(LuceneSearchEngineQuery query)
Sub classes should implement this. |
protected Resource[] |
doGet(ResourceKey resourceKey)
Base classes should implement this. |
protected LuceneSearchEngineInternalSearch |
doInternalSearch(String[] subIndexes,
String[] aliases)
Base classes should implement this. |
protected void |
doPrepare()
Sub classes should implement this. |
protected void |
doProcessJob(TransactionJob job)
Sub classes should implement the actual processing of a transactional job. |
protected void |
doRollback()
Sub classes should implement this. |
protected String[] |
getDirtySubIndexes()
Returns the current dirty sub indexes. |
String |
getName()
Retuns the name of this transaction processor. |
protected IndexWriter |
getOrCreateIndexWriter(String subIndex)
|
protected void |
prepareBeforeAsyncDirtyOperation(TransactionJob job)
Just open an index writer here on the same calling thread so we maintain ordering of operations as well as no need for double check if we created it or not using expensive global locking. |
Methods inherited from class org.compass.core.lucene.engine.transaction.support.AbstractConcurrentTransactionProcessor |
---|
begin, commit, create, delete, delete, doFlush, find, flush, flushCommit, get, internalSearch, isConcurrentOperations, prepare, rollback, update |
Methods inherited from class org.compass.core.lucene.engine.transaction.support.AbstractSearchTransactionProcessor |
---|
performFind, performGet, performInternalSearch |
Methods inherited from class org.compass.core.lucene.engine.transaction.support.AbstractTransactionProcessor |
---|
buildInternalSearch, findByQuery, getResourceMapping, getSettingName, isInvalidateCacheOnCommit |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Constructor Detail |
---|
public LuceneTransactionProcessor(LuceneSearchEngine searchEngine)
Method Detail |
---|
public String getName()
TransactionProcessor
protected String[] getDirtySubIndexes()
AbstractConcurrentTransactionProcessor
getDirtySubIndexes
in class AbstractConcurrentTransactionProcessor
protected void doRollback() throws SearchEngineException
AbstractConcurrentTransactionProcessor
AbstractConcurrentTransactionProcessor.rollback()
.
doRollback
in class AbstractConcurrentTransactionProcessor
SearchEngineException
protected void doPrepare() throws SearchEngineException
AbstractConcurrentTransactionProcessor
AbstractConcurrentTransactionProcessor.prepare()
.
doPrepare
in class AbstractConcurrentTransactionProcessor
SearchEngineException
protected void doCommit(boolean onePhase) throws SearchEngineException
AbstractConcurrentTransactionProcessor
AbstractConcurrentTransactionProcessor.commit(boolean)
.
doCommit
in class AbstractConcurrentTransactionProcessor
SearchEngineException
protected void doProcessJob(TransactionJob job) throws SearchEngineException
AbstractConcurrentTransactionProcessor
doProcessJob
in class AbstractConcurrentTransactionProcessor
SearchEngineException
protected LuceneSearchEngineHits doFind(LuceneSearchEngineQuery query) throws SearchEngineException
AbstractConcurrentTransactionProcessor
AbstractConcurrentTransactionProcessor.find(org.compass.core.lucene.engine.LuceneSearchEngineQuery)
.
doFind
in class AbstractConcurrentTransactionProcessor
SearchEngineException
protected LuceneSearchEngineInternalSearch doInternalSearch(String[] subIndexes, String[] aliases) throws SearchEngineException
AbstractConcurrentTransactionProcessor
AbstractConcurrentTransactionProcessor.internalSearch(String[], String[])
.
doInternalSearch
in class AbstractConcurrentTransactionProcessor
SearchEngineException
protected Resource[] doGet(ResourceKey resourceKey) throws SearchEngineException
AbstractConcurrentTransactionProcessor
AbstractConcurrentTransactionProcessor.get(org.compass.core.spi.ResourceKey)
.
doGet
in class AbstractConcurrentTransactionProcessor
SearchEngineException
protected void prepareBeforeAsyncDirtyOperation(TransactionJob job) throws SearchEngineException
prepareBeforeAsyncDirtyOperation
in class AbstractConcurrentTransactionProcessor
SearchEngineException
protected IndexWriter getOrCreateIndexWriter(String subIndex) throws IOException
IOException
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |