|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object dk.netarkivet.harvester.datamodel.RunningJobsInfoDAO dk.netarkivet.harvester.datamodel.RunningJobsInfoDBDAO
public class RunningJobsInfoDBDAO
Class implementing the persistence of running job infos.
Constructor Summary | |
---|---|
RunningJobsInfoDBDAO()
|
Method Summary | |
---|---|
int |
deleteFrontierReports(long jobId)
Deletes all frontier report data pertaining to the given job id from the persistent storage. |
InMemoryFrontierReport |
getFrontierReport(long jobId,
java.lang.String filterId)
Retrieve a frontier report from a job id and a given filter class. |
java.lang.String[] |
getFrontierReportFilterTypes()
Returns the list of tyhe available frontier report types. |
StartedJobInfo[] |
getFullJobHistory(long jobId)
Returns an array of all progress records chronologically sorted for the given job ID. |
java.util.Set<java.lang.Long> |
getHistoryRecordIds()
Returns the ids of jobs for which history records exist as an immutable set. |
java.util.Map<java.lang.String,java.util.List<StartedJobInfo>> |
getMostRecentByHarvestName()
Returns the most recent record for every job, partitioned by harvest definition name. |
StartedJobInfo |
getMostRecentByJobId(long jobId)
Returns the most recent progress record for the given job ID. |
StartedJobInfo[] |
getMostRecentByJobId(long jobId,
long startTime,
int limit)
Returns an array of chronologically sorted progress records for the given job ID, starting at a given crawl time, and limited to a given number of record. |
int |
removeInfoForJob(long jobId)
Removes all records pertaining to the given job ID from the persistent storage. |
void |
store(StartedJobInfo startedJobInfo)
Stores a StartedJobInfo record to the persistent storage. |
int |
storeFrontierReport(java.lang.String filterId,
InMemoryFrontierReport report)
Store frontier report data to the persistent storage. |
Methods inherited from class dk.netarkivet.harvester.datamodel.RunningJobsInfoDAO |
---|
getInstance |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Constructor Detail |
---|
public RunningJobsInfoDBDAO()
Method Detail |
---|
public void store(StartedJobInfo startedJobInfo)
StartedJobInfo
record to the persistent storage.
The record is stored in the monitor table, and if the elapsed time since
the last history sample is equal or superior to the history sample rate,
also to the history table.
store
in class RunningJobsInfoDAO
startedJobInfo
- the record to store.public StartedJobInfo[] getFullJobHistory(long jobId)
getFullJobHistory
in class RunningJobsInfoDAO
jobId
- the job id.
public java.util.Map<java.lang.String,java.util.List<StartedJobInfo>> getMostRecentByHarvestName()
getMostRecentByHarvestName
in class RunningJobsInfoDAO
public java.util.Set<java.lang.Long> getHistoryRecordIds()
getHistoryRecordIds
in class RunningJobsInfoDAO
public StartedJobInfo[] getMostRecentByJobId(long jobId, long startTime, int limit)
getMostRecentByJobId
in class RunningJobsInfoDAO
jobId
- the job id.startTime
- the crawl time (in seconds) to begin.limit
- the maximum number of records to fetch.
public StartedJobInfo getMostRecentByJobId(long jobId)
getMostRecentByJobId
in class RunningJobsInfoDAO
jobId
- the job id.
public int removeInfoForJob(long jobId)
removeInfoForJob
in class RunningJobsInfoDAO
jobId
- the job id.
public int storeFrontierReport(java.lang.String filterId, InMemoryFrontierReport report)
storeFrontierReport
in class RunningJobsInfoDAO
report
- the report to storefilterId
- the id of the filter that produced the report
public java.lang.String[] getFrontierReportFilterTypes()
getFrontierReportFilterTypes
in class RunningJobsInfoDAO
FrontierReportFilter.getFilterId()
public InMemoryFrontierReport getFrontierReport(long jobId, java.lang.String filterId)
getFrontierReport
in class RunningJobsInfoDAO
jobId
- the job idfilterId
- the id of the filter that produced the report
public int deleteFrontierReports(long jobId)
deleteFrontierReports
in class RunningJobsInfoDAO
jobId
- the job id
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |