org.alfresco.solr

Class SolrInformationServer

java.lang.Object

org.alfresco.solr.SolrInformationServer

All Implemented Interfaces:

InformationServer, org.alfresco.solr.InformationServerCollectionProvider

public class SolrInformationServer
extends Object
implements InformationServer

This is the Solr4 implementation of the information server (index).

Since:

5.0

Author:

Ahmed Owian

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
protected static class	SolrInformationServer.FTSStatus

Field Summary

Fields

Modifier and Type	Field and Description
static String	AND
static int	BATCH_FACET_TXS
static String	DOC_TYPE_ACL
static String	DOC_TYPE_ACL_TX
static String	DOC_TYPE_ERROR_NODE
static String	DOC_TYPE_NODE
static String	DOC_TYPE_STATE
static String	DOC_TYPE_TX
static String	DOC_TYPE_UNINDEXED_NODE
static String	FINGERPRINT_FIELD
static String	indexCapId
protected static org.slf4j.Logger	log
static String	OR
static String	PREFIX_ERROR
static String	REQUEST_HANDLER_ALFRESCO
static String	REQUEST_HANDLER_ALFRESCO_FULL_TEXT_SEARCH
static String	REQUEST_HANDLER_GET
static String	REQUEST_HANDLER_NATIVE
static String	REQUEST_HANDLER_SELECT
static String	RESPONSE_DEFAULT_ID
static String	RESPONSE_DEFAULT_IDS
static String	SOLR_BASEURL
static String	SOLR_HOST
static String	SOLR_PORT

Fields inherited from interface org.alfresco.solr.InformationServer

PROP_PREFIX_PARENT_ASPECT, PROP_PREFIX_PARENT_TYPE

Constructor Summary

Constructors

Constructor and Description
SolrInformationServer(AlfrescoCoreAdminHandler adminHandler, org.apache.solr.core.SolrCore core, org.alfresco.solr.client.SOLRAPIClient repositoryClient, SolrContentStore solrContentStore)

Method Summary

Modifier and Type	Method and Description
boolean	aclChangeSetInIndex(long changeSetId, boolean populateCache)
void	addCommonNodeReportInfo(org.alfresco.solr.NodeReport nodeReport)
void	addFTSStatusCounts(org.apache.solr.common.util.NamedList<Object> report)
void	afterInitModels()
void	capIndex(long dbid)
void	cascadeNodes(List<org.alfresco.solr.client.NodeMetaData> nodeMetaDatas, boolean overwrite)
org.alfresco.solr.AclReport	checkAclInIndex(Long aclid, org.alfresco.solr.AclReport aclReport)
void	clearProcessedAclChangeSets()
void	clearProcessedTransactions()
void	commit()
boolean	commit(boolean openSearcher)
void	continueState(org.alfresco.solr.TrackerState state)
void	deleteByAclChangeSetId(Long aclChangeSetId)
void	deleteByAclId(Long aclId)
void	deleteByNodeId(Long nodeId)
void	deleteByTransactionId(Long transactionId)
void	dirtyTransaction(long txnId)
int	getAclTxDocsSize(String aclTxId, String aclTxCommitTime)
AlfrescoCoreAdminHandler	getAdminHandler()
List<org.alfresco.solr.client.AlfrescoModel>	getAlfrescoModels()
String	getAlfrescoVersion()
String	getBaseUrl()
List<org.alfresco.solr.client.NodeMetaData>	getCascadeNodes(List<Long> txnIds)
List<org.alfresco.solr.client.Transaction>	getCascades(int num)
Iterable<Map.Entry<String,Object>>	getCoreStats()
org.alfresco.repo.dictionary.DictionaryComponent	getDictionaryService(String alternativeDictionary)
List<AlfrescoSolrDataModel.TenantAclIdDbId>	getDocsWithUncleanContent(int start, int rows)
Set<Long>	getErrorDocIds()
long	getHoleRetention()
String	getHostName()
long	getIndexCap()
org.alfresco.repo.dictionary.M2Model	getM2Model(org.alfresco.service.namespace.QName modelQName)
org.alfresco.solr.client.AclChangeSet	getMaxAclChangeSetIdAndCommitTimeInIndex()
org.alfresco.solr.client.Transaction	getMaxTransactionIdAndCommitTimeInIndex()
Map<String,Set<String>>	getModelErrors()
org.alfresco.repo.dictionary.NamespaceDAO	getNamespaceDAO()
org.alfresco.solr.adapters.IOpenBitSet	getOpenBitSetInstance()
int	getPort()
Properties	getProps()
int	getRegisteredSearcherCount()
<T> org.alfresco.solr.adapters.ISimpleOrderedMap<T>	getSimpleOrderedMapInstance()
SolrContentStore	getSolrContentStore()
org.alfresco.solr.TrackerState	getTrackerInitialState()
org.alfresco.solr.tracker.TrackerStats	getTrackerStats()
int	getTxDocsSize(String targetTxId, String targetTxCommitTime)
void	hardCommit()
long	indexAcl(List<org.alfresco.solr.client.AclReaders> aclReaderList, boolean overwrite)
void	indexAclTransaction(org.alfresco.solr.client.AclChangeSet changeSet, boolean overwrite)
void	indexNode(org.alfresco.solr.client.Node node, boolean overwrite)
void	indexNodes(List<org.alfresco.solr.client.Node> nodes, boolean overwrite, boolean cascade)
void	indexTransaction(org.alfresco.solr.client.Transaction info, boolean overwrite)
void	initSkippingDescendantDocs()
boolean	isInIndex(String id)
void	maintainCap(long dbid)
long	maxNodeId()
long	minNodeId()
long	nodeCount()
void	putAclTransactionState(org.apache.solr.update.processor.UpdateRequestProcessor processor, org.apache.solr.request.SolrQueryRequest request, org.alfresco.solr.client.AclChangeSet changeSet)
boolean	putModel(org.alfresco.repo.dictionary.M2Model model)
void	putTransactionState(org.apache.solr.update.processor.UpdateRequestProcessor processor, org.apache.solr.request.SolrQueryRequest request, org.alfresco.solr.client.Transaction tx) Puts the latest transaction state onto the index
void	registerTrackerThread()
void	reindexNodeByQuery(String query)
org.alfresco.solr.tracker.IndexHealthReport	reportAclTransactionsInIndex(Long minAclTxId, org.alfresco.solr.adapters.IOpenBitSet aclTxIdsInDb, long maxAclTxId)
org.alfresco.solr.tracker.IndexHealthReport	reportIndexTransactions(Long minTxId, org.alfresco.solr.adapters.IOpenBitSet txIdsInDb, long maxTxId)
void	rollback()
void	setCleanCascadeTxnFloor(long cleanCascadeTxnFloor)
void	setCleanContentTxnFloor(long cleanContentTxnFloor)
boolean	txnInIndex(long txnId, boolean populateCache)
void	unregisterTrackerThread()
void	updateContentToIndexAndCache(long dbId, String tenant)
void	updateTransaction(org.alfresco.solr.client.Transaction txn)

Methods inherited from class java.lang.Object

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

Field Detail

AND

public static final String AND

See Also:

Constant Field Values

OR

public static final String OR

See Also:

Constant Field Values

REQUEST_HANDLER_ALFRESCO_FULL_TEXT_SEARCH

public static final String REQUEST_HANDLER_ALFRESCO_FULL_TEXT_SEARCH

See Also:

Constant Field Values

REQUEST_HANDLER_NATIVE

public static final String REQUEST_HANDLER_NATIVE

See Also:

Constant Field Values

REQUEST_HANDLER_ALFRESCO

public static final String REQUEST_HANDLER_ALFRESCO

See Also:

Constant Field Values

REQUEST_HANDLER_SELECT

public static final String REQUEST_HANDLER_SELECT

See Also:

Constant Field Values

REQUEST_HANDLER_GET

public static final String REQUEST_HANDLER_GET

See Also:

Constant Field Values

RESPONSE_DEFAULT_IDS

public static final String RESPONSE_DEFAULT_IDS

See Also:

Constant Field Values

RESPONSE_DEFAULT_ID

public static final String RESPONSE_DEFAULT_ID

See Also:

Constant Field Values

PREFIX_ERROR

public static final String PREFIX_ERROR

See Also:

Constant Field Values

DOC_TYPE_NODE

public static final String DOC_TYPE_NODE

See Also:

Constant Field Values

DOC_TYPE_UNINDEXED_NODE

public static final String DOC_TYPE_UNINDEXED_NODE

See Also:

Constant Field Values

DOC_TYPE_ERROR_NODE

public static final String DOC_TYPE_ERROR_NODE

See Also:

Constant Field Values

DOC_TYPE_ACL

public static final String DOC_TYPE_ACL

See Also:

Constant Field Values

DOC_TYPE_TX

public static final String DOC_TYPE_TX

See Also:

Constant Field Values

DOC_TYPE_ACL_TX

public static final String DOC_TYPE_ACL_TX

See Also:

Constant Field Values

DOC_TYPE_STATE

public static final String DOC_TYPE_STATE

See Also:

Constant Field Values

SOLR_HOST

public static final String SOLR_HOST

See Also:

Constant Field Values

SOLR_PORT

public static final String SOLR_PORT

See Also:

Constant Field Values

SOLR_BASEURL

public static final String SOLR_BASEURL

See Also:

Constant Field Values

indexCapId

public static String indexCapId

BATCH_FACET_TXS

public static final int BATCH_FACET_TXS

See Also:

Constant Field Values

FINGERPRINT_FIELD

public static final String FINGERPRINT_FIELD

See Also:

Constant Field Values

log

protected static final org.slf4j.Logger log

Constructor Detail

SolrInformationServer

public SolrInformationServer(AlfrescoCoreAdminHandler adminHandler,
                             org.apache.solr.core.SolrCore core,
                             org.alfresco.solr.client.SOLRAPIClient repositoryClient,
                             SolrContentStore solrContentStore)

Method Detail

getAdminHandler

public AlfrescoCoreAdminHandler getAdminHandler()

Specified by:

getAdminHandler in interface InformationServer

initSkippingDescendantDocs

public void initSkippingDescendantDocs()

Specified by:

initSkippingDescendantDocs in interface InformationServer

addFTSStatusCounts

public void addFTSStatusCounts(org.apache.solr.common.util.NamedList<Object> report)

Specified by:

addFTSStatusCounts in interface InformationServer

getAlfrescoVersion

public String getAlfrescoVersion()

afterInitModels

public void afterInitModels()

Specified by:

afterInitModels in interface InformationServer

checkAclInIndex

public org.alfresco.solr.AclReport checkAclInIndex(Long aclid,
                                                   org.alfresco.solr.AclReport aclReport)

Specified by:

checkAclInIndex in interface InformationServer

reportIndexTransactions

public org.alfresco.solr.tracker.IndexHealthReport reportIndexTransactions(Long minTxId,
                                                                           org.alfresco.solr.adapters.IOpenBitSet txIdsInDb,
                                                                           long maxTxId)
                                                                    throws IOException

Specified by:

reportIndexTransactions in interface InformationServer

Throws:

IOException

reportAclTransactionsInIndex

public org.alfresco.solr.tracker.IndexHealthReport reportAclTransactionsInIndex(Long minAclTxId,
                                                                                org.alfresco.solr.adapters.IOpenBitSet aclTxIdsInDb,
                                                                                long maxAclTxId)

Specified by:

reportAclTransactionsInIndex in interface InformationServer

getDocsWithUncleanContent

public List<AlfrescoSolrDataModel.TenantAclIdDbId> getDocsWithUncleanContent(int start,
                                                                             int rows)
                                                                      throws IOException

Specified by:

getDocsWithUncleanContent in interface InformationServer

Throws:

IOException

addCommonNodeReportInfo

public void addCommonNodeReportInfo(org.alfresco.solr.NodeReport nodeReport)

Specified by:

addCommonNodeReportInfo in interface InformationServer

commit

public void commit()
            throws IOException

Specified by:

commit in interface InformationServer

Throws:

IOException

hardCommit

public void hardCommit()
                throws IOException

Specified by:

hardCommit in interface InformationServer

Throws:

IOException

commit

public boolean commit(boolean openSearcher)
               throws IOException

Specified by:

commit in interface InformationServer

Throws:

IOException

deleteByAclChangeSetId

public void deleteByAclChangeSetId(Long aclChangeSetId)
                            throws IOException

Specified by:

deleteByAclChangeSetId in interface InformationServer

Throws:

IOException

deleteByAclId

public void deleteByAclId(Long aclId)
                   throws IOException

Specified by:

deleteByAclId in interface InformationServer

Throws:

IOException

deleteByNodeId

public void deleteByNodeId(Long nodeId)
                    throws IOException

Specified by:

deleteByNodeId in interface InformationServer

Throws:

IOException

deleteByTransactionId

public void deleteByTransactionId(Long transactionId)
                           throws IOException

Specified by:

deleteByTransactionId in interface InformationServer

Throws:

IOException

getAlfrescoModels

public List<org.alfresco.solr.client.AlfrescoModel> getAlfrescoModels()

Specified by:

getAlfrescoModels in interface InformationServer

getCoreStats

public Iterable<Map.Entry<String,Object>> getCoreStats()
                                                throws IOException

Specified by:

getCoreStats in interface InformationServer

Throws:

IOException

getDictionaryService

public org.alfresco.repo.dictionary.DictionaryComponent getDictionaryService(String alternativeDictionary)

Specified by:

getDictionaryService in interface InformationServer

getTxDocsSize

public int getTxDocsSize(String targetTxId,
                         String targetTxCommitTime)
                  throws IOException

Specified by:

getTxDocsSize in interface InformationServer

Throws:

IOException

getAclTxDocsSize

public int getAclTxDocsSize(String aclTxId,
                            String aclTxCommitTime)
                     throws IOException

Specified by:

getAclTxDocsSize in interface InformationServer

Throws:

IOException

getErrorDocIds

public Set<Long> getErrorDocIds()
                         throws IOException

Specified by:

getErrorDocIds in interface InformationServer

Throws:

IOException

getHoleRetention

public long getHoleRetention()

Specified by:

getHoleRetention in interface InformationServer

getM2Model

public org.alfresco.repo.dictionary.M2Model getM2Model(org.alfresco.service.namespace.QName modelQName)

Specified by:

getM2Model in interface InformationServer

getModelErrors

public Map<String,Set<String>> getModelErrors()

Specified by:

getModelErrors in interface InformationServer

getNamespaceDAO

public org.alfresco.repo.dictionary.NamespaceDAO getNamespaceDAO()

Specified by:

getNamespaceDAO in interface InformationServer

getOpenBitSetInstance

public org.alfresco.solr.adapters.IOpenBitSet getOpenBitSetInstance()

Specified by:

getOpenBitSetInstance in interface org.alfresco.solr.InformationServerCollectionProvider

getRegisteredSearcherCount

public int getRegisteredSearcherCount()

Specified by:

getRegisteredSearcherCount in interface InformationServer

getSimpleOrderedMapInstance

public <T> org.alfresco.solr.adapters.ISimpleOrderedMap<T> getSimpleOrderedMapInstance()

Specified by:

getSimpleOrderedMapInstance in interface org.alfresco.solr.InformationServerCollectionProvider

getTrackerStats

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

Specified by:

getTrackerStats in interface InformationServer

getTrackerInitialState

public org.alfresco.solr.TrackerState getTrackerInitialState()

Specified by:

getTrackerInitialState in interface InformationServer

continueState

public void continueState(org.alfresco.solr.TrackerState state)

Specified by:

continueState in interface InformationServer

indexAcl

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

Specified by:

indexAcl in interface InformationServer

Throws:

IOException

indexAclTransaction

public void indexAclTransaction(org.alfresco.solr.client.AclChangeSet changeSet,
                                boolean overwrite)
                         throws IOException

Specified by:

indexAclTransaction in interface InformationServer

Throws:

IOException

getMaxAclChangeSetIdAndCommitTimeInIndex

public org.alfresco.solr.client.AclChangeSet getMaxAclChangeSetIdAndCommitTimeInIndex()

Specified by:

getMaxAclChangeSetIdAndCommitTimeInIndex in interface InformationServer

dirtyTransaction

public void dirtyTransaction(long txnId)

Specified by:

dirtyTransaction in interface InformationServer

putAclTransactionState

public void putAclTransactionState(org.apache.solr.update.processor.UpdateRequestProcessor processor,
                                   org.apache.solr.request.SolrQueryRequest request,
                                   org.alfresco.solr.client.AclChangeSet changeSet)
                            throws IOException

Throws:

IOException

capIndex

public void capIndex(long dbid)
              throws IOException

Specified by:

capIndex in interface InformationServer

Throws:

IOException

maintainCap

public void maintainCap(long dbid)
                 throws IOException

Specified by:

maintainCap in interface InformationServer

Throws:

IOException

nodeCount

public long nodeCount()

Specified by:

nodeCount in interface InformationServer

maxNodeId

public long maxNodeId()

Specified by:

maxNodeId in interface InformationServer

minNodeId

public long minNodeId()

Specified by:

minNodeId in interface InformationServer

getIndexCap

public long getIndexCap()

Specified by:

getIndexCap in interface InformationServer

indexNode

public void indexNode(org.alfresco.solr.client.Node node,
                      boolean overwrite)
               throws IOException,
                      org.alfresco.httpclient.AuthenticationException,
                      org.json.JSONException

Specified by:

indexNode in interface InformationServer

Throws:

IOException

org.alfresco.httpclient.AuthenticationException

org.json.JSONException

getCascadeNodes

public List<org.alfresco.solr.client.NodeMetaData> getCascadeNodes(List<Long> txnIds)
                                                            throws org.alfresco.httpclient.AuthenticationException,
                                                                   IOException,
                                                                   org.json.JSONException

Specified by:

getCascadeNodes in interface InformationServer

Throws:

org.alfresco.httpclient.AuthenticationException

IOException

org.json.JSONException

indexNodes

public void indexNodes(List<org.alfresco.solr.client.Node> nodes,
                       boolean overwrite,
                       boolean cascade)
                throws IOException,
                       org.alfresco.httpclient.AuthenticationException,
                       org.json.JSONException

Specified by:

indexNodes in interface InformationServer

Throws:

IOException

org.alfresco.httpclient.AuthenticationException

org.json.JSONException

cascadeNodes

public void cascadeNodes(List<org.alfresco.solr.client.NodeMetaData> nodeMetaDatas,
                         boolean overwrite)
                  throws IOException,
                         org.alfresco.httpclient.AuthenticationException,
                         org.json.JSONException

Specified by:

cascadeNodes in interface InformationServer

Throws:

IOException

org.alfresco.httpclient.AuthenticationException

org.json.JSONException

updateContentToIndexAndCache

public void updateContentToIndexAndCache(long dbId,
                                         String tenant)
                                  throws Exception

Specified by:

updateContentToIndexAndCache in interface InformationServer

Throws:

Exception

updateTransaction

public void updateTransaction(org.alfresco.solr.client.Transaction txn)
                       throws IOException

Specified by:

updateTransaction in interface InformationServer

Throws:

IOException

indexTransaction

public void indexTransaction(org.alfresco.solr.client.Transaction info,
                             boolean overwrite)
                      throws IOException

Specified by:

indexTransaction in interface InformationServer

Throws:

IOException

getMaxTransactionIdAndCommitTimeInIndex

public org.alfresco.solr.client.Transaction getMaxTransactionIdAndCommitTimeInIndex()

Specified by:

getMaxTransactionIdAndCommitTimeInIndex in interface InformationServer

putTransactionState

public void putTransactionState(org.apache.solr.update.processor.UpdateRequestProcessor processor,
                                org.apache.solr.request.SolrQueryRequest request,
                                org.alfresco.solr.client.Transaction tx)
                         throws IOException

Puts the latest transaction state onto the index

Parameters:

processor - UpdateRequestProcessor

request - SolrQueryRequest

tx - Transaction

Throws:

IOException

isInIndex

public boolean isInIndex(String id)
                  throws IOException

Specified by:

isInIndex in interface InformationServer

Parameters:

id - String

Throws:

IOException

getCascades

public List<org.alfresco.solr.client.Transaction> getCascades(int num)
                                                       throws IOException

Specified by:

getCascades in interface InformationServer

Throws:

IOException

txnInIndex

public boolean txnInIndex(long txnId,
                          boolean populateCache)
                   throws IOException

Specified by:

txnInIndex in interface InformationServer

Throws:

IOException

aclChangeSetInIndex

public boolean aclChangeSetInIndex(long changeSetId,
                                   boolean populateCache)
                            throws IOException

Specified by:

aclChangeSetInIndex in interface InformationServer

Throws:

IOException

clearProcessedTransactions

public void clearProcessedTransactions()

Specified by:

clearProcessedTransactions in interface InformationServer

clearProcessedAclChangeSets

public void clearProcessedAclChangeSets()

Specified by:

clearProcessedAclChangeSets in interface InformationServer

putModel

public boolean putModel(org.alfresco.repo.dictionary.M2Model model)

Specified by:

putModel in interface InformationServer

rollback

public void rollback()
              throws IOException

Specified by:

rollback in interface InformationServer

Throws:

IOException

registerTrackerThread

public void registerTrackerThread()

Specified by:

registerTrackerThread in interface InformationServer

unregisterTrackerThread

public void unregisterTrackerThread()

Specified by:

unregisterTrackerThread in interface InformationServer

reindexNodeByQuery

public void reindexNodeByQuery(String query)
                        throws IOException,
                               org.alfresco.httpclient.AuthenticationException,
                               org.json.JSONException

Specified by:

reindexNodeByQuery in interface InformationServer

Throws:

IOException

org.alfresco.httpclient.AuthenticationException

org.json.JSONException

getBaseUrl

public String getBaseUrl()

Specified by:

getBaseUrl in interface InformationServer

getPort

public int getPort()

Specified by:

getPort in interface InformationServer

getHostName

public String getHostName()

Specified by:

getHostName in interface InformationServer

setCleanContentTxnFloor

public void setCleanContentTxnFloor(long cleanContentTxnFloor)

Specified by:

setCleanContentTxnFloor in interface InformationServer

setCleanCascadeTxnFloor

public void setCleanCascadeTxnFloor(long cleanCascadeTxnFloor)

Specified by:

setCleanCascadeTxnFloor in interface InformationServer

getSolrContentStore

public SolrContentStore getSolrContentStore()

getProps

public Properties getProps()