Modifier and Type | Class and Description |
---|---|
class |
BaseRepositoryConnector
This base class describes an instance of a connection between a repository and ManifoldCF's
standard "pull" ingestion agent.
|
Modifier and Type | Method and Description |
---|---|
static IRepositoryConnector |
RepositoryConnectorFactory.getConnectorNoCheck(String className)
Get a repository connector instance, without checking for installed connector.
|
IRepositoryConnector |
IRepositoryConnectorPool.grab(IRepositoryConnection repositoryConnection)
Get a repository connector.
|
IRepositoryConnector[] |
IRepositoryConnectorPool.grabMultiple(String[] orderingKeys,
IRepositoryConnection[] authorityConnections)
Get multiple repository connectors, all at once.
|
Modifier and Type | Method and Description |
---|---|
void |
IRepositoryConnectorPool.release(IRepositoryConnection connection,
IRepositoryConnector connector)
Release a repository connector.
|
void |
IRepositoryConnectorPool.releaseMultiple(IRepositoryConnection[] connections,
IRepositoryConnector[] connectors)
Release multiple repository connectors.
|
Modifier and Type | Field and Description |
---|---|
protected Map<String,IRepositoryConnector> |
JobManager.ThrottleLimit.activeConnections |
Modifier and Type | Method and Description |
---|---|
void |
JobManager.ThrottleLimit.addConnectionName(String connectionName,
IRepositoryConnector connectorInstance)
Add an active connection.
|
Modifier and Type | Method and Description |
---|---|
IRepositoryConnector |
RepositoryConnectorPool.grab(IRepositoryConnection repositoryConnection)
Get a repository connector.
|
IRepositoryConnector[] |
RepositoryConnectorPool.LocalPool.grabMultiple(IThreadContext tc,
String[] orderingKeys,
String[] connectionNames,
String[] classNames,
ConfigParams[] configInfos,
int[] maxPoolSizes) |
IRepositoryConnector[] |
RepositoryConnectorPool.grabMultiple(String[] orderingKeys,
IRepositoryConnection[] repositoryConnections)
Get multiple repository connectors, all at once.
|
Modifier and Type | Method and Description |
---|---|
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 IRepositoryConnector |
SeedingActivity.connector |
protected IRepositoryConnector |
WorkerThread.ProcessActivity.connector |
Modifier and Type | Method and Description |
---|---|
static String[] |
ManifoldCF.calculateBins(IRepositoryConnector connector,
String documentIdentifier)
Given a connector object and a document identifier, calculate its bins.
|
protected static void |
WorkerThread.processDeleteLists(IPipelineConnections pipelineConnections,
IRepositoryConnector connector,
IRepositoryConnection connection,
IJobManager jobManager,
List<QueuedDocument> deleteList,
IIncrementalIngester ingester,
Long jobID,
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,
List<QueuedDocument> hopcountremoveList,
IIncrementalIngester ingester,
Long jobID,
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(List<QueuedDocument> jobmanagerDeleteList,
IRepositoryConnector connector,
IRepositoryConnection connection,
IJobManager jobManager,
Long jobID,
String[] legalLinkTypes,
int hopcountMethod,
IReprioritizationTracker rt,
long currentTime)
Process job queue deletions.
|
protected static void |
WorkerThread.processJobQueueHopcountRemovals(List<QueuedDocument> jobmanagerRemovalList,
IRepositoryConnector connector,
IRepositoryConnection connection,
IJobManager jobManager,
Long jobID,
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.
|
Constructor and Description |
---|
SeedingActivity(String connectionName,
IRepositoryConnectionManager connManager,
IJobManager jobManager,
IReprioritizationTracker rt,
IRepositoryConnection connection,
IRepositoryConnector connector,
Long jobID,
String[] legalLinkTypes,
boolean overrideSchedule,
int hopcountMethod,
String processID)
Constructor.
|
WorkerThread.ProcessActivity(Long jobID,
String processID,
IReprioritizationTracker rt,
IJobManager jobManager,
IIncrementalIngester ingester,
String connectionName,
IPipelineSpecification pipelineSpecification,
Map<String,QueuedDocument> previousDocuments,
long currentTime,
Long expireInterval,
Map<String,Set<String>> forcedMetadata,
Long recrawlInterval,
Long maxInterval,
int hopcountMode,
IRepositoryConnection connection,
IRepositoryConnector connector,
IRepositoryConnectionManager connMgr,
String[] legalLinkTypes,
WorkerThread.OutputActivity ingestLogger,
String parameterVersion)
Constructor.
|