org.alfresco.solr

Class LegacySolrInformationServer

java.lang.Object

org.alfresco.solr.LegacySolrInformationServer

All Implemented Interfaces:

InformationServer, org.alfresco.solr.InformationServerCollectionProvider, org.apache.solr.core.CloseHook

public class LegacySolrInformationServer
extends Object
implements org.apache.solr.core.CloseHook, InformationServer

This class interfaces with the old Solr Information Search Server.

Author:

Ahmed Owian

Field Summary

Fields

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

Fields inherited from interface org.alfresco.solr.InformationServer

PROP_PREFIX_PARENT_ASPECT, PROP_PREFIX_PARENT_TYPE

Constructor Summary

Constructors

Constructor and Description
LegacySolrInformationServer(AlfrescoCoreAdminHandler adminHandler, org.apache.solr.core.SolrCore core)

Method Summary

Modifier and Type	Method and Description
void	afterInitModels()
org.alfresco.solr.AclReport	checkAclInIndex(Long aclid, org.alfresco.solr.AclReport aclReport)
void	checkCache()
org.alfresco.solr.tracker.IndexHealthReport	checkIndexTransactions(org.alfresco.solr.tracker.IndexHealthReport indexHealthReport, Long minTxId, Long minAclTxId, org.alfresco.solr.adapters.IOpenBitSet txIdsInDb, long maxTxId, org.alfresco.solr.adapters.IOpenBitSet aclTxIdsInDb, long maxAclTxId)
org.alfresco.solr.NodeReport	checkNodeCommon(org.alfresco.solr.NodeReport nodeReport)
void	close(org.apache.solr.core.SolrCore core)
void	commit()
void	deleteByAclChangeSetId(Long aclChangeSetId)
void	deleteByAclId(Long aclId)
void	deleteByNodeId(Long nodeId)
void	deleteByTransactionId(Long transactionId)
List<org.alfresco.solr.client.AlfrescoModel>	getAlfrescoModels()
Iterable<Map.Entry<String,Object>>	getCoreStats()
org.alfresco.repo.dictionary.DictionaryComponent	getDictionaryService(String alternativeDictionary)
int	getDocSetSize(String targetTxId, String targetTxCommitTime)
Set<Long>	getErrorDocIds()
long	getHoleRetention()
org.alfresco.repo.dictionary.M2Model	getM2Model(org.alfresco.service.namespace.QName modelQName)
Map<String,Set<String>>	getModelErrors()
org.alfresco.repo.dictionary.NamespaceDAO	getNamespaceDAO()
org.alfresco.solr.adapters.IOpenBitSet	getOpenBitSetInstance()
int	getRegisteredSearcherCount()
protected List<org.apache.solr.search.SolrIndexSearcher>	getRegisteredSearchers()
<T> org.alfresco.solr.adapters.ISimpleOrderedMap<T>	getSimpleOrderedMapInstance()
Tracker	getTracker()
org.alfresco.solr.TrackerState	getTrackerInitialState()
org.alfresco.solr.TrackerState	getTrackerState()
org.alfresco.solr.tracker.TrackerStats	getTrackerStats()
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	indexTransaction(org.alfresco.solr.client.Transaction info, boolean overwrite)
boolean	isInIndex(String fieldType, long id)
boolean	putModel(org.alfresco.repo.dictionary.M2Model model)
void	rollback()
static org.apache.lucene.document.Document	toDocument(org.apache.solr.common.SolrInputDocument doc, org.apache.solr.schema.IndexSchema schema, AlfrescoSolrDataModel model)

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

Constructor Detail

LegacySolrInformationServer

public LegacySolrInformationServer(AlfrescoCoreAdminHandler adminHandler,
                                   org.apache.solr.core.SolrCore core)

Method Detail

close

public void close(org.apache.solr.core.SolrCore core)

Specified by:

close in interface org.apache.solr.core.CloseHook

rollback

public void rollback()
              throws IOException

Specified by:

rollback in interface InformationServer

Throws:

IOException

commit

public void commit()
            throws IOException

Specified by:

commit in interface InformationServer

Throws:

IOException

toDocument

public static org.apache.lucene.document.Document toDocument(org.apache.solr.common.SolrInputDocument doc,
                                                             org.apache.solr.schema.IndexSchema schema,
                                                             AlfrescoSolrDataModel model)

getRegisteredSearchers

protected List<org.apache.solr.search.SolrIndexSearcher> getRegisteredSearchers()

getCoreStats

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

Specified by:

getCoreStats in interface InformationServer

Throws:

IOException

checkNodeCommon

public org.alfresco.solr.NodeReport checkNodeCommon(org.alfresco.solr.NodeReport nodeReport)

Specified by:

checkNodeCommon in interface InformationServer

indexTransaction

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

Specified by:

indexTransaction 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

deleteByTransactionId

public void deleteByTransactionId(Long transactionId)
                           throws IOException

Specified by:

deleteByTransactionId in interface InformationServer

Throws:

IOException

deleteByNodeId

public void deleteByNodeId(Long nodeId)
                    throws IOException

Specified by:

deleteByNodeId in interface InformationServer

Throws:

IOException

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

getErrorDocIds

public Set<Long> getErrorDocIds()
                         throws IOException

Specified by:

getErrorDocIds 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

indexAcl

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

Specified by:

indexAcl in interface InformationServer

Throws:

IOException

getTrackerInitialState

public org.alfresco.solr.TrackerState getTrackerInitialState()
                                                      throws IOException

Specified by:

getTrackerInitialState in interface InformationServer

Throws:

IOException

getTrackerState

public org.alfresco.solr.TrackerState getTrackerState()

Specified by:

getTrackerState in interface InformationServer

getDocSetSize

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

Specified by:

getDocSetSize in interface InformationServer

Throws:

IOException

getRegisteredSearcherCount

public int getRegisteredSearcherCount()

Specified by:

getRegisteredSearcherCount in interface InformationServer

checkCache

public void checkCache()
                throws IOException

Specified by:

checkCache in interface InformationServer

Throws:

IOException

isInIndex

public boolean isInIndex(String fieldType,
                         long id)
                  throws IOException

Specified by:

isInIndex in interface InformationServer

Throws:

IOException

checkAclInIndex

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

Specified by:

checkAclInIndex in interface InformationServer

checkIndexTransactions

public org.alfresco.solr.tracker.IndexHealthReport checkIndexTransactions(org.alfresco.solr.tracker.IndexHealthReport indexHealthReport,
                                                                          Long minTxId,
                                                                          Long minAclTxId,
                                                                          org.alfresco.solr.adapters.IOpenBitSet txIdsInDb,
                                                                          long maxTxId,
                                                                          org.alfresco.solr.adapters.IOpenBitSet aclTxIdsInDb,
                                                                          long maxAclTxId)
                                                                   throws IOException

Specified by:

checkIndexTransactions in interface InformationServer

Throws:

IOException

getTracker

public Tracker getTracker()

getModelErrors

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

Specified by:

getModelErrors in interface InformationServer

getOpenBitSetInstance

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

Specified by:

getOpenBitSetInstance in interface org.alfresco.solr.InformationServerCollectionProvider

getSimpleOrderedMapInstance

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

Specified by:

getSimpleOrderedMapInstance in interface org.alfresco.solr.InformationServerCollectionProvider

getDictionaryService

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

Specified by:

getDictionaryService in interface InformationServer

getNamespaceDAO

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

Specified by:

getNamespaceDAO in interface InformationServer

getAlfrescoModels

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

Specified by:

getAlfrescoModels in interface InformationServer

afterInitModels

public void afterInitModels()

Specified by:

afterInitModels in interface InformationServer

putModel

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

Specified by:

putModel in interface InformationServer

getM2Model

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

Specified by:

getM2Model in interface InformationServer

getHoleRetention

public long getHoleRetention()

Specified by:

getHoleRetention in interface InformationServer

getTrackerStats

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

Specified by:

getTrackerStats in interface InformationServer