org.alfresco.solr.tracker

Class MetadataTracker

java.lang.Object

org.alfresco.solr.tracker.AbstractTracker

org.alfresco.solr.tracker.MetadataTracker

All Implemented Interfaces:

Tracker

public class MetadataTracker
extends AbstractTracker
implements Tracker

Nested Class Summary

Nested classes/interfaces inherited from interface org.alfresco.solr.tracker.Tracker

Tracker.Type

Field Summary

Fields

Modifier and Type	Field and Description
protected static org.slf4j.Logger	log

Fields inherited from class org.alfresco.solr.tracker.AbstractTracker

alfrescoVersion, batchCount, client, coreName, infoSrv, isMaster, isSlave, props, rollback, runPostModelLoadInit, SHARD_METHOD_ACLID, SHARD_METHOD_DBID, shardCount, shardInstance, shardMethod, shardTemplate, state, storeRef, threadHandler, TIME_STEP_1_HR_IN_MS, TIME_STEP_32_DAYS_IN_MS, trackerStats, transformContent, type

Constructor Summary

Constructors

Constructor and Description
MetadataTracker(Properties p, SOLRAPIClient client, String coreName, InformationServer informationServer)

Method Summary

Modifier and Type	Method and Description
void	addNodeToIndex(Long nodeId)
void	addNodeToPurge(Long nodeId)
void	addNodeToReindex(Long nodeId)
void	addQueryToReindex(String query)
void	addTransactionToIndex(Long txId)
void	addTransactionToPurge(Long txId)
void	addTransactionToReindex(Long txId)
IndexHealthReport	checkIndex(Long toTx, Long toAclTx, Long fromTime, Long toTime)
NodeReport	checkNode(Long dbid)
NodeReport	checkNode(Node node)
protected void	doTrack() Subclasses must implement behaviour that completes the following steps, in order: Purge Reindex Index Track repository
DocRouter	getDocRouter()
List<Node>	getFullNodesForDbTransaction(Long txid)
static org.alfresco.service.namespace.QName	getShardProperty(String field)
protected Transactions	getSomeTransactions(BoundedDeque<Transaction> txnsFound, Long fromCommitTime, long timeStep, int maxResults, long endTime)
protected Long	getTxFromCommitTime(BoundedDeque<Transaction> txnsFound, long lastGoodTxCommitTimeInIndex)
boolean	hasMaintenance()
void	invalidateState()
void	maintenance()
protected void	trackTransactions()

Methods inherited from class org.alfresco.solr.tracker.AbstractTracker

checkShutdown, getAlfrescoVersion, getMaxLiveSearchers, getProps, getRollback, getRunLock, getTrackerState, getType, getWriteLock, setRollback, setShutdown, shutdown, track, waitForAsynchronous

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.alfresco.solr.tracker.Tracker

getAlfrescoVersion, getProps, getRollback, getTrackerState, getType, getWriteLock, setRollback, setShutdown, shutdown, track

Field Detail

log

protected static final org.slf4j.Logger log

Constructor Detail

MetadataTracker

public MetadataTracker(Properties p,
                       SOLRAPIClient client,
                       String coreName,
                       InformationServer informationServer)

Method Detail

getDocRouter

public DocRouter getDocRouter()

doTrack

protected void doTrack()
                throws org.alfresco.httpclient.AuthenticationException,
                       IOException,
                       org.json.JSONException,
                       org.apache.commons.codec.EncoderException

Description copied from class: AbstractTracker

Subclasses must implement behaviour that completes the following steps, in order:

1. Purge
2. Reindex
3. Index
4. Track repository

Specified by:

doTrack in class AbstractTracker

Throws:

org.alfresco.httpclient.AuthenticationException

IOException

org.json.JSONException

org.apache.commons.codec.EncoderException

maintenance

public void maintenance()
                 throws Exception

Specified by:

maintenance in interface Tracker

Throws:

Exception

hasMaintenance

public boolean hasMaintenance()
                       throws Exception

Specified by:

hasMaintenance in interface Tracker

Throws:

Exception

getTxFromCommitTime

protected Long getTxFromCommitTime(BoundedDeque<Transaction> txnsFound,
                                   long lastGoodTxCommitTimeInIndex)

getSomeTransactions

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

Throws:

org.alfresco.httpclient.AuthenticationException

IOException

org.json.JSONException

org.apache.commons.codec.EncoderException

trackTransactions

protected void trackTransactions()
                          throws org.alfresco.httpclient.AuthenticationException,
                                 IOException,
                                 org.json.JSONException,
                                 org.apache.commons.codec.EncoderException

Throws:

org.alfresco.httpclient.AuthenticationException

IOException

org.json.JSONException

org.apache.commons.codec.EncoderException

checkNode

public NodeReport checkNode(Long dbid)

checkNode

public NodeReport checkNode(Node node)

getFullNodesForDbTransaction

public List<Node> getFullNodesForDbTransaction(Long txid)

checkIndex

public IndexHealthReport checkIndex(Long toTx,
                                    Long toAclTx,
                                    Long fromTime,
                                    Long toTime)
                             throws IOException,
                                    org.alfresco.httpclient.AuthenticationException,
                                    org.json.JSONException,
                                    org.apache.commons.codec.EncoderException

Throws:

IOException

org.alfresco.httpclient.AuthenticationException

org.json.JSONException

org.apache.commons.codec.EncoderException

addTransactionToPurge

public void addTransactionToPurge(Long txId)

addNodeToPurge

public void addNodeToPurge(Long nodeId)

addTransactionToReindex

public void addTransactionToReindex(Long txId)

addNodeToReindex

public void addNodeToReindex(Long nodeId)

addTransactionToIndex

public void addTransactionToIndex(Long txId)

addNodeToIndex

public void addNodeToIndex(Long nodeId)

invalidateState

public void invalidateState()

Specified by:

invalidateState in interface Tracker

Overrides:

invalidateState in class AbstractTracker

addQueryToReindex

public void addQueryToReindex(String query)

Parameters:

query -

getShardProperty

public static org.alfresco.service.namespace.QName getShardProperty(String field)