Package | Description |
---|---|
org.apache.manifoldcf.crawler.interfaces | |
org.apache.manifoldcf.crawler.jobs | |
org.apache.manifoldcf.crawler.system |
Modifier and Type | Method and Description |
---|---|
IJobDescription |
IJobManager.createJob()
Create a new job.
|
IJobDescription[] |
IJobManager.findJobsForConnection(java.lang.String connectionName)
Get the job IDs associated with a given connection name.
|
IJobDescription[] |
IJobManager.getAllJobs()
Load a sorted list of job descriptions.
|
IJobDescription |
IJobManager.load(java.lang.Long id)
Load a job for editing.
|
IJobDescription |
IJobManager.load(java.lang.Long id,
boolean readOnly)
Load a job.
|
Modifier and Type | Method and Description |
---|---|
void |
IJobManager.save(IJobDescription jobDescription)
Save a job.
|
Modifier and Type | Method and Description |
---|---|
void |
IJobManager.finishJobResumes(long timestamp,
java.util.List<IJobDescription> modifiedJobs)
Complete the sequence that resumes jobs, either from a pause or from a scheduling window
wait.
|
void |
IJobManager.finishJobStops(long timestamp,
java.util.List<IJobDescription> modifiedJobs,
java.util.List<java.lang.Integer> stopNotificationTypes)
Complete the sequence that stops jobs, either for abort, pause, or because of a scheduling
window.
|
void |
IJobManager.resetJobs(long currentTime,
java.util.List<IJobDescription> resetJobs)
Reset eligible jobs either back to the "inactive" state, or make them active again.
|
Modifier and Type | Class and Description |
---|---|
class |
JobDescription
This is a paper object describing a job.
|
Modifier and Type | Method and Description |
---|---|
IJobDescription |
Jobs.create()
Create a job.
|
IJobDescription |
JobManager.createJob()
Create a new job.
|
IJobDescription[] |
JobManager.findJobsForConnection(java.lang.String connectionName)
Get the job IDs associated with a given connection name.
|
IJobDescription[] |
Jobs.findJobsForConnection(java.lang.String connectionName)
Get the job IDs associated with a given connection name.
|
IJobDescription[] |
Jobs.getAll()
Get a list of all jobs which are not in the process of being deleted already.
|
IJobDescription[] |
JobManager.getAllJobs()
Load a sorted list of job descriptions.
|
IJobDescription |
JobManager.load(java.lang.Long id)
Load a job for editing.
|
IJobDescription |
JobManager.load(java.lang.Long id,
boolean readOnly)
Load a job.
|
IJobDescription |
Jobs.load(java.lang.Long id,
boolean readOnly)
Load a job for editing.
|
IJobDescription[] |
Jobs.loadMultiple(java.lang.Long[] ids,
boolean[] readOnlies)
Load multiple jobs for editing.
|
Modifier and Type | Method and Description |
---|---|
boolean |
HopFilterManager.compareRows(java.lang.Long ownerID,
IJobDescription list)
Compare a filter list against what's in a job description.
|
boolean |
NotificationManager.compareRows(java.lang.Long ownerID,
IJobDescription job)
Compare rows in job description with what's currently in the database.
|
boolean |
PipelineManager.compareRows(java.lang.Long ownerID,
IJobDescription job)
Compare rows in job description with what's currently in the database.
|
protected int |
Jobs.loadMultipleInternal(IJobDescription[] rval,
int outputIndex,
java.lang.Long[] ids,
boolean[] readOnlies,
int inputIndex,
int length) |
void |
JobManager.save(IJobDescription jobDescription)
Save a job.
|
void |
Jobs.save(IJobDescription jobDescription)
Save a job description.
|
void |
HopFilterManager.writeRows(java.lang.Long ownerID,
IJobDescription list)
Write a filter list into the database.
|
void |
NotificationManager.writeRows(java.lang.Long ownerID,
IJobDescription job)
Write a pipeline list into the database.
|
void |
PipelineManager.writeRows(java.lang.Long ownerID,
IJobDescription job)
Write a pipeline list into the database.
|
void |
ScheduleManager.writeRows(java.lang.Long ownerID,
IJobDescription list)
Write a schedule list into the database.
|
Modifier and Type | Method and Description |
---|---|
void |
JobManager.finishJobResumes(long timestamp,
java.util.List<IJobDescription> modifiedJobs)
Complete the sequence that resumes jobs, either from a pause or from a scheduling window
wait.
|
void |
JobManager.finishJobStops(long timestamp,
java.util.List<IJobDescription> modifiedJobs,
java.util.List<java.lang.Integer> stopNotificationTypes)
Complete the sequence that stops jobs, either for abort, pause, or because of a scheduling
window.
|
void |
JobManager.resetJobs(long currentTime,
java.util.List<IJobDescription> resetJobs)
Reset eligible jobs either back to the "inactive" state, or make them active again.
|
Modifier and Type | Field and Description |
---|---|
protected IJobDescription |
PipelineSpecificationBasic.job |
protected IJobDescription |
DocumentCleanupSet.jobDescription
The job description for this set of documents.
|
protected IJobDescription |
DocumentDeleteSet.jobDescription
The job description for this set of documents.
|
protected IJobDescription |
QueuedDocumentSet.jobDescription
The job description that applies to this document set.
|
Modifier and Type | Method and Description |
---|---|
IJobDescription |
DocumentCleanupSet.getJobDescription()
Get the job description.
|
IJobDescription |
DocumentDeleteSet.getJobDescription()
Get the job description.
|
IJobDescription |
QueuedDocumentSet.getJobDescription()
Get the job description.
|
Modifier and Type | Method and Description |
---|---|
protected static void |
JobResetThread.doEndNotifications(IJobDescription jobDescription,
INotificationConnectionManager notificationManager,
INotificationConnectorPool notificationPool) |
protected static void |
JobResetThread.doStopNotifications(IJobDescription jobDescription,
int notificationType,
INotificationConnectionManager notificationManager,
INotificationConnectorPool notificationPool) |
protected static void |
ManifoldCF.formatJobDescription(ConfigurationNode jobNode,
IJobDescription job)
Convert a job description into a ConfigurationNode.
|
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 |
---|
DocumentCleanupSet(CleanupQueuedDocument[] documents,
IJobDescription jobDescription)
Constructor.
|
DocumentDeleteSet(DeleteQueuedDocument[] documents,
IJobDescription jobDescription)
Constructor.
|
PipelineSpecification(IPipelineConnections connections,
IJobDescription job,
IIncrementalIngester ingester) |
PipelineSpecificationBasic(IJobDescription job) |
QueuedDocumentSet(java.util.List<QueuedDocument> documents,
IJobDescription jobDescription,
IRepositoryConnection connection)
Constructor.
|