Modifier and Type | Method and 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.
|
Modifier and Type | Method and 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.
|
Modifier and Type | Method and 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
|
Modifier and Type | Class and Description |
---|---|
class |
RepositoryConnection
An instance of this class represents a persistently-stored repository connection description.
|
Modifier and Type | Method and 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.
|
Modifier and Type | Method and 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.
|
Modifier and Type | Method and 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.
|
Modifier and Type | Field and 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 |
Modifier and Type | Method and Description |
---|---|
IRepositoryConnection |
QueuedDocumentSet.getConnection()
Get the connection.
|
Modifier and Type | Method and 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.
|
Modifier and Type | Method and 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.
|
Constructor and 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) |