Uses of Interface
org.apache.manifoldcf.crawler.interfaces.IRepositoryConnection
-
-
Uses of IRepositoryConnection in org.apache.manifoldcf.crawler.interfaces
Methods in org.apache.manifoldcf.crawler.interfaces that return IRepositoryConnection Modifier and Type Method Description IRepositoryConnection
IRepositoryConnectionManager. create()
Create a new repository connection object.IRepositoryConnection[]
IRepositoryConnectionManager. getAllConnections()
Obtain a list of the repository connections, ordered by name.IRepositoryConnection
IRepositoryConnectionManager. load(java.lang.String name)
Load a repository connection by name.IRepositoryConnection[]
IRepositoryConnectionManager. loadMultiple(java.lang.String[] names)
Load a set of repository connections.Methods in org.apache.manifoldcf.crawler.interfaces with parameters of type IRepositoryConnection Modifier and Type Method Description double
QueueTracker. calculateAssignmentRating(java.lang.String[] binNames, IRepositoryConnection connection)
Calculate an assignment rating for a set of bins based on what's currently in use.IRepositoryConnector
IRepositoryConnectorPool. grab(IRepositoryConnection repositoryConnection)
Get a repository connector.IRepositoryConnector[]
IRepositoryConnectorPool. grabMultiple(java.lang.String[] orderingKeys, IRepositoryConnection[] authorityConnections)
Get multiple repository connectors, all at once.void
IRepositoryConnectorPool. release(IRepositoryConnection connection, IRepositoryConnector connector)
Release a repository connector.void
IRepositoryConnectorPool. releaseMultiple(IRepositoryConnection[] connections, IRepositoryConnector[] connectors)
Release multiple repository connectors.boolean
IRepositoryConnectionManager. save(IRepositoryConnection object)
Save a repository connection object. -
Uses of IRepositoryConnection in org.apache.manifoldcf.crawler.jobs
Methods in org.apache.manifoldcf.crawler.jobs with parameters of type IRepositoryConnection Modifier and Type Method Description protected void
JobManager. fetchAndProcessDocuments(java.util.List<DocumentDescription> answers, java.lang.Long currentTimeValue, java.lang.Long currentPriorityValue, JobManager.ThrottleLimit vList, IRepositoryConnection[] connections, java.lang.String processID)
Fetch and process documents matching the passed-in criteria -
Uses of IRepositoryConnection in org.apache.manifoldcf.crawler.repository
Classes in org.apache.manifoldcf.crawler.repository that implement IRepositoryConnection Modifier and Type Class Description class
RepositoryConnection
An instance of this class represents a persistently-stored repository connection description.Methods in org.apache.manifoldcf.crawler.repository that return IRepositoryConnection Modifier and Type Method Description IRepositoryConnection
RepositoryConnectionManager. create()
Create a new repository connection object.IRepositoryConnection[]
RepositoryConnectionManager. getAllConnections()
Obtain a list of the repository connections, ordered by name.IRepositoryConnection
RepositoryConnectionManager. load(java.lang.String name)
Load a repository connection by name.IRepositoryConnection[]
RepositoryConnectionManager. loadMultiple(java.lang.String[] names)
Load multiple repository connections by name.Methods in org.apache.manifoldcf.crawler.repository with parameters of type IRepositoryConnection Modifier and Type Method Description void
ThrottleSpecManager. getRows(IRepositoryConnection[] connections, java.util.Map indexMap, java.util.ArrayList ownerNameParams)
Fill in a set of throttles corresponding to a set of connection names.protected int
RepositoryConnectionManager. loadMultipleInternal(IRepositoryConnection[] rval, int outputIndex, java.lang.String[] fetchNames, int inputIndex, int length)
boolean
RepositoryConnectionManager. save(IRepositoryConnection object)
Save a repository connection object.void
ThrottleSpecManager. writeRows(java.lang.String owner, IRepositoryConnection connection)
Write a throttle spec into the database. -
Uses of IRepositoryConnection in org.apache.manifoldcf.crawler.repositoryconnectorpool
Methods in org.apache.manifoldcf.crawler.repositoryconnectorpool with parameters of type IRepositoryConnection Modifier and Type Method Description IRepositoryConnector
RepositoryConnectorPool. grab(IRepositoryConnection repositoryConnection)
Get a repository connector.IRepositoryConnector[]
RepositoryConnectorPool. grabMultiple(java.lang.String[] orderingKeys, IRepositoryConnection[] repositoryConnections)
Get multiple repository connectors, all at once.void
RepositoryConnectorPool. release(IRepositoryConnection connection, IRepositoryConnector connector)
Release a repository connector.void
RepositoryConnectorPool. releaseMultiple(IRepositoryConnection[] connections, IRepositoryConnector[] connectors)
Release multiple repository connectors. -
Uses of IRepositoryConnection in org.apache.manifoldcf.crawler.system
Fields in org.apache.manifoldcf.crawler.system declared as IRepositoryConnection Modifier and Type Field Description protected IRepositoryConnection
PriorityCalculator. connection
protected IRepositoryConnection
QueuedDocumentSet. connection
The connection description that applies to this document set.protected IRepositoryConnection
SeedingActivity. connection
protected IRepositoryConnection
WorkerThread.ProcessActivity. connection
Methods in org.apache.manifoldcf.crawler.system that return IRepositoryConnection Modifier and Type Method Description IRepositoryConnection
QueuedDocumentSet. getConnection()
Get the connection.Methods in org.apache.manifoldcf.crawler.system with parameters of type IRepositoryConnection Modifier and Type Method Description protected static double[]
PriorityCalculator. calculateMaxFetchRates(java.lang.String[] binNames, IRepositoryConnection connection)
Calculate the maximum fetch rate for a given set of bins for a given connection.protected static void
ManifoldCF. formatRepositoryConnection(ConfigurationNode connectionNode, IRepositoryConnection connection)
Format a repository connection.protected static void
WorkerThread. processDeleteLists(IPipelineConnections pipelineConnections, IRepositoryConnector connector, IRepositoryConnection connection, IJobManager jobManager, java.util.List<QueuedDocument> deleteList, IIncrementalIngester ingester, java.lang.Long jobID, java.lang.String[] legalLinkTypes, WorkerThread.OutputActivity ingestLogger, int hopcountMethod, IReprioritizationTracker rt, long currentTime)
Clear specified documents out of the job queue and from the appliance.protected static void
WorkerThread. processHopcountRemovalLists(IPipelineConnections pipelineConnections, IRepositoryConnector connector, IRepositoryConnection connection, IJobManager jobManager, java.util.List<QueuedDocument> hopcountremoveList, IIncrementalIngester ingester, java.lang.Long jobID, java.lang.String[] legalLinkTypes, WorkerThread.OutputActivity ingestLogger, int hopcountMethod, IReprioritizationTracker rt, long currentTime)
Mark specified documents as 'hopcount removed', and remove them from the index.protected static void
WorkerThread. processJobQueueDeletions(java.util.List<QueuedDocument> jobmanagerDeleteList, IRepositoryConnector connector, IRepositoryConnection connection, IJobManager jobManager, java.lang.Long jobID, java.lang.String[] legalLinkTypes, int hopcountMethod, IReprioritizationTracker rt, long currentTime)
Process job queue deletions.protected static void
WorkerThread. processJobQueueHopcountRemovals(java.util.List<QueuedDocument> jobmanagerRemovalList, IRepositoryConnector connector, IRepositoryConnection connection, IJobManager jobManager, java.lang.Long jobID, java.lang.String[] legalLinkTypes, int hopcountMethod, IReprioritizationTracker rt, long currentTime)
Process job queue hopcount removals.static void
ManifoldCF. requeueDocumentsDueToCarrydown(IJobManager jobManager, DocumentDescription[] requeueCandidates, IRepositoryConnector connector, IRepositoryConnection connection, IReprioritizationTracker rt, long currentTime)
Requeue documents due to carrydown.Method parameters in org.apache.manifoldcf.crawler.system with type arguments of type IRepositoryConnection Modifier and Type Method Description static void
ManifoldCF. writeDocumentPriorities(IThreadContext threadContext, DocumentDescription[] descs, java.util.Map<java.lang.String,IRepositoryConnection> connectionMap, java.util.Map<java.lang.Long,IJobDescription> jobDescriptionMap)
Write a set of document priorities, based on the current queue tracker.Constructors in org.apache.manifoldcf.crawler.system with parameters of type IRepositoryConnection Constructor Description PriorityCalculator(IReprioritizationTracker rt, double currentMinimumDepth, IRepositoryConnection connection, java.lang.String[] documentBins, java.lang.String documentIdentifier)
PriorityCalculator(IReprioritizationTracker rt, IRepositoryConnection connection, java.lang.String[] documentBins, java.lang.String documentIdentifier)
Constructor.ProcessActivity(java.lang.Long jobID, java.lang.String processID, IReprioritizationTracker rt, IJobManager jobManager, IIncrementalIngester ingester, java.lang.String connectionName, IPipelineSpecification pipelineSpecification, java.util.Map<java.lang.String,QueuedDocument> previousDocuments, long currentTime, java.lang.Long expireInterval, java.lang.Long recrawlInterval, java.lang.Long maxInterval, int hopcountMode, IRepositoryConnection connection, IRepositoryConnector connector, IRepositoryConnectionManager connMgr, java.lang.String[] legalLinkTypes, WorkerThread.OutputActivity ingestLogger)
Constructor.QueuedDocumentSet(java.util.List<QueuedDocument> documents, IJobDescription jobDescription, IRepositoryConnection connection)
Constructor.SeedingActivity(java.lang.String connectionName, IRepositoryConnectionManager connManager, IJobManager jobManager, IReprioritizationTracker rt, IRepositoryConnection connection, IRepositoryConnector connector, java.lang.Long jobID, java.lang.String[] legalLinkTypes, boolean overrideSchedule, int hopcountMethod, java.lang.String processID)
Constructor.ThrottleLimits(IRepositoryConnection connection)
-