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.
|
protected static java.util.List<QueuedDocument> |
WorkerThread.removeFromIndex(IPipelineConnections pipelineConnections,
java.lang.String connectionName,
IJobManager jobManager,
java.util.List<QueuedDocument> deleteList,
IIncrementalIngester ingester,
WorkerThread.OutputActivity ingestLogger) |
Remove a specified set of documents from the index.
|
protected static void |
WorkerThread.requeueDocuments(IJobManager jobManager,
java.util.List<QueuedDocument> requeueList,
long retryTime,
long failTime,
int failCount) |
Requeue documents after a service interruption was detected.
|
static void |
ManifoldCF.requeueDocumentsDueToCarrydown(IJobManager jobManager,
DocumentDescription[] requeueCandidates,
IRepositoryConnector connector,
IRepositoryConnection connection,
IReprioritizationTracker rt,
long currentTime) |
Requeue documents due to carrydown.
|