org.alfresco.solr.tracker

Class CoreTracker

java.lang.Object

org.alfresco.solr.tracker.CoreTracker

All Implemented Interfaces:

Tracker

Direct Known Subclasses:

MultiThreadedCoreTracker

public class CoreTracker
extends Object
implements Tracker

Field Summary

Fields

Modifier and Type	Field and Description
protected long	batchCount
protected org.alfresco.solr.client.SOLRAPIClient	client
protected InformationServer	infoSrv
protected static org.slf4j.Logger	log
protected Properties	props
protected org.alfresco.service.cmr.repository.StoreRef	storeRef
protected org.alfresco.solr.tracker.TrackerStats	trackerStats

Constructor Summary

Constructors

Constructor and Description
CoreTracker(org.quartz.Scheduler scheduler, String id, Properties p, SolrKeyResourceLoader keyResourceLoader, String coreName, InformationServer informationServer)

Method Summary

Modifier and Type	Method and Description
void	addAclChangeSetToIndex(Long aclChangeSetToIndex)
void	addAclChangeSetToPurge(Long aclChangeSetToPurge)
void	addAclChangeSetToReindex(Long aclChangeSetToReindex)
void	addAclToIndex(Long aclToIndex)
void	addAclToPurge(Long aclToPurge)
void	addAclToReindex(Long aclToReindex)
void	addNodeToIndex(Long nodeToIndex)
void	addNodeToPurge(Long nodeToPurge)
void	addNodeToReindex(Long nodeToReindex)
void	addTransactionToIndex(Long transactionToIndex)
void	addTransactionToPurge(Long transactionToPurge)
void	addTransactionToReindex(Long transactionToReindex)
boolean	canAddContentPropertyToDoc()
org.alfresco.solr.AclReport	checkAcl(Long aclid)
org.alfresco.solr.tracker.IndexHealthReport	checkIndex(Long fromTx, Long toTx, Long fromAclTx, Long toAclTx, Long fromTime, Long toTime)
org.alfresco.solr.NodeReport	checkNode(Long dbid)
org.alfresco.solr.NodeReport	checkNode(org.alfresco.solr.client.Node node)
protected void	checkShutdown()
void	close()
void	ensureFirstModelSync()
List<Long>	getAclsForDbAclTransaction(Long acltxid)
String	getAlfrescoVersion()
protected Long	getChangeSetFromCommitTime(org.alfresco.solr.BoundedDeque<org.alfresco.solr.client.AclChangeSet> changeSetsFound, long lastGoodChangeSetCommitTimeInIndex)
List<org.alfresco.solr.client.Node>	getFullNodesForDbTransaction(Long txid)
int	getMaxLiveSearchers()
List<org.alfresco.solr.client.NodeMetaData>	getNodesMetaData(org.alfresco.solr.client.NodeMetaDataParameters params, int maxResults)
protected org.alfresco.httpclient.AlfrescoHttpClient	getRepoClient(SolrKeyResourceLoader keyResourceLoader)
protected org.alfresco.solr.client.AclChangeSets	getSomeAclChangeSets(org.alfresco.solr.BoundedDeque<org.alfresco.solr.client.AclChangeSet> changeSetsFound, Long fromCommitTime, long timeStep, int maxResults, long endTime)
protected org.alfresco.solr.client.Transactions	getSomeTransactions(org.alfresco.solr.BoundedDeque<org.alfresco.solr.client.Transaction> txnsFound, Long fromCommitTime, long timeStep, int maxResults, long endTime)
org.alfresco.solr.client.SOLRAPIClient.GetTextContentResponse	getTextContent(Long nodeId, org.alfresco.service.namespace.QName propertyQName, Long modifiedSince)
org.alfresco.solr.tracker.TrackerStats	getTrackerStats()
protected Long	getTxFromCommitTime(org.alfresco.solr.BoundedDeque<org.alfresco.solr.client.Transaction> txnsFound, long lastGoodTxCommitTimeInIndex)
protected void	indexAcl(List<org.alfresco.solr.client.AclReaders> aclReaderList, boolean overwrite)
void	setShutdown(boolean shutdown)
protected void	trackAclChangeSets()
void	trackModels(boolean onlyFirstTime)
protected void	trackTransactions()
void	updateIndex()

Methods inherited from class java.lang.Object

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

Field Detail

log

protected static final org.slf4j.Logger log

client

protected org.alfresco.solr.client.SOLRAPIClient client

props

protected Properties props

infoSrv

protected InformationServer infoSrv

storeRef

protected org.alfresco.service.cmr.repository.StoreRef storeRef

batchCount

protected long batchCount

trackerStats

protected org.alfresco.solr.tracker.TrackerStats trackerStats

Constructor Detail

CoreTracker

public CoreTracker(org.quartz.Scheduler scheduler,
                   String id,
                   Properties p,
                   SolrKeyResourceLoader keyResourceLoader,
                   String coreName,
                   InformationServer informationServer)

Method Detail

getTrackerStats

public org.alfresco.solr.tracker.TrackerStats getTrackerStats()

Specified by:

getTrackerStats in interface Tracker

getMaxLiveSearchers

public int getMaxLiveSearchers()

Specified by:

getMaxLiveSearchers in interface Tracker

getRepoClient

protected org.alfresco.httpclient.AlfrescoHttpClient getRepoClient(SolrKeyResourceLoader keyResourceLoader)

updateIndex

public void updateIndex()

Specified by:

updateIndex in interface Tracker

checkShutdown

protected void checkShutdown()

addTransactionToReindex

public void addTransactionToReindex(Long transactionToReindex)

Specified by:

addTransactionToReindex in interface Tracker

addTransactionToIndex

public void addTransactionToIndex(Long transactionToIndex)

Specified by:

addTransactionToIndex in interface Tracker

addTransactionToPurge

public void addTransactionToPurge(Long transactionToPurge)

Specified by:

addTransactionToPurge in interface Tracker

addNodeToReindex

public void addNodeToReindex(Long nodeToReindex)

Specified by:

addNodeToReindex in interface Tracker

addNodeToIndex

public void addNodeToIndex(Long nodeToIndex)

Specified by:

addNodeToIndex in interface Tracker

addNodeToPurge

public void addNodeToPurge(Long nodeToPurge)

Specified by:

addNodeToPurge in interface Tracker

addAclChangeSetToReindex

public void addAclChangeSetToReindex(Long aclChangeSetToReindex)

Specified by:

addAclChangeSetToReindex in interface Tracker

addAclChangeSetToIndex

public void addAclChangeSetToIndex(Long aclChangeSetToIndex)

Specified by:

addAclChangeSetToIndex in interface Tracker

addAclChangeSetToPurge

public void addAclChangeSetToPurge(Long aclChangeSetToPurge)

Specified by:

addAclChangeSetToPurge in interface Tracker

addAclToReindex

public void addAclToReindex(Long aclToReindex)

Specified by:

addAclToReindex in interface Tracker

addAclToIndex

public void addAclToIndex(Long aclToIndex)

Specified by:

addAclToIndex in interface Tracker

addAclToPurge

public void addAclToPurge(Long aclToPurge)

Specified by:

addAclToPurge in interface Tracker

trackTransactions

protected void trackTransactions()
                          throws org.alfresco.httpclient.AuthenticationException,
                                 IOException,
                                 org.json.JSONException

Throws:

org.alfresco.httpclient.AuthenticationException

IOException

org.json.JSONException

trackAclChangeSets

protected void trackAclChangeSets()
                           throws org.alfresco.httpclient.AuthenticationException,
                                  IOException,
                                  org.json.JSONException

Throws:

org.alfresco.httpclient.AuthenticationException

IOException

org.json.JSONException

getTxFromCommitTime

protected Long getTxFromCommitTime(org.alfresco.solr.BoundedDeque<org.alfresco.solr.client.Transaction> txnsFound,
                                   long lastGoodTxCommitTimeInIndex)

Parameters:

lastGoodTxCommitTimeInIndex - long

Returns:

Long

getChangeSetFromCommitTime

protected Long getChangeSetFromCommitTime(org.alfresco.solr.BoundedDeque<org.alfresco.solr.client.AclChangeSet> changeSetsFound,
                                          long lastGoodChangeSetCommitTimeInIndex)

Parameters:

lastGoodChangeSetCommitTimeInIndex - long

Returns:

Long

getSomeAclChangeSets

protected org.alfresco.solr.client.AclChangeSets getSomeAclChangeSets(org.alfresco.solr.BoundedDeque<org.alfresco.solr.client.AclChangeSet> changeSetsFound,
                                                                      Long fromCommitTime,
                                                                      long timeStep,
                                                                      int maxResults,
                                                                      long endTime)
                                                               throws org.alfresco.httpclient.AuthenticationException,
                                                                      IOException,
                                                                      org.json.JSONException

Throws:

org.alfresco.httpclient.AuthenticationException

IOException

org.json.JSONException

getSomeTransactions

protected org.alfresco.solr.client.Transactions getSomeTransactions(org.alfresco.solr.BoundedDeque<org.alfresco.solr.client.Transaction> txnsFound,
                                                                    Long fromCommitTime,
                                                                    long timeStep,
                                                                    int maxResults,
                                                                    long endTime)
                                                             throws org.alfresco.httpclient.AuthenticationException,
                                                                    IOException,
                                                                    org.json.JSONException

Throws:

org.alfresco.httpclient.AuthenticationException

IOException

org.json.JSONException

indexAcl

protected void indexAcl(List<org.alfresco.solr.client.AclReaders> aclReaderList,
                        boolean overwrite)
                 throws IOException

Parameters:

overwrite - boolean

Throws:

IOException

checkIndex

public org.alfresco.solr.tracker.IndexHealthReport checkIndex(Long fromTx,
                                                              Long toTx,
                                                              Long fromAclTx,
                                                              Long toAclTx,
                                                              Long fromTime,
                                                              Long toTime)
                                                       throws org.alfresco.httpclient.AuthenticationException,
                                                              IOException,
                                                              org.json.JSONException

Specified by:

checkIndex in interface Tracker

Throws:

org.alfresco.httpclient.AuthenticationException

IOException

org.json.JSONException

checkNode

public org.alfresco.solr.NodeReport checkNode(org.alfresco.solr.client.Node node)

Specified by:

checkNode in interface Tracker

checkNode

public org.alfresco.solr.NodeReport checkNode(Long dbid)

Specified by:

checkNode in interface Tracker

Parameters:

dbid - Long

Returns:

NodeReport

getFullNodesForDbTransaction

public List<org.alfresco.solr.client.Node> getFullNodesForDbTransaction(Long txid)

Specified by:

getFullNodesForDbTransaction in interface Tracker

getAclsForDbAclTransaction

public List<Long> getAclsForDbAclTransaction(Long acltxid)

Specified by:

getAclsForDbAclTransaction in interface Tracker

Parameters:

acltxid - Long

checkAcl

public org.alfresco.solr.AclReport checkAcl(Long aclid)

Specified by:

checkAcl in interface Tracker

close

public void close()

Specified by:

close in interface Tracker

trackModels

public void trackModels(boolean onlyFirstTime)
                 throws org.alfresco.httpclient.AuthenticationException,
                        IOException,
                        org.json.JSONException

Specified by:

trackModels in interface Tracker

Throws:

org.alfresco.httpclient.AuthenticationException

IOException

org.json.JSONException

ensureFirstModelSync

public void ensureFirstModelSync()

Specified by:

ensureFirstModelSync in interface Tracker

getAlfrescoVersion

public String getAlfrescoVersion()

Specified by:

getAlfrescoVersion in interface Tracker

Returns:

Alfresco version Solr was built for

setShutdown

public void setShutdown(boolean shutdown)

Specified by:

setShutdown in interface Tracker

getNodesMetaData

public List<org.alfresco.solr.client.NodeMetaData> getNodesMetaData(org.alfresco.solr.client.NodeMetaDataParameters params,
                                                                    int maxResults)
                                                             throws org.alfresco.httpclient.AuthenticationException,
                                                                    IOException,
                                                                    org.json.JSONException

Specified by:

getNodesMetaData in interface Tracker

Throws:

org.alfresco.httpclient.AuthenticationException

IOException

org.json.JSONException

getTextContent

public org.alfresco.solr.client.SOLRAPIClient.GetTextContentResponse getTextContent(Long nodeId,
                                                                                    org.alfresco.service.namespace.QName propertyQName,
                                                                                    Long modifiedSince)
                                                                             throws org.alfresco.httpclient.AuthenticationException,
                                                                                    IOException

Specified by:

getTextContent in interface Tracker

Throws:

org.alfresco.httpclient.AuthenticationException

IOException

canAddContentPropertyToDoc

public boolean canAddContentPropertyToDoc()

Specified by:

canAddContentPropertyToDoc in interface Tracker