Package com.denodo.scheduler.client.job.report

Class DatabaseJobReport

java.lang.Object

com.denodo.scheduler.client.job.report.BaseJobReport

com.denodo.scheduler.client.job.report.AbstractExtractionJobReport

com.denodo.scheduler.client.job.report.ExtractionJobReport

com.denodo.scheduler.client.job.report.DatabaseJobReport

All Implemented Interfaces:

JobReport, JobReportWithChildren<DatabaseJobReport>, Serializable

Direct Known Subclasses:

VDPIndexerJobReport, VDPViewIndexingProcessReport

public class DatabaseJobReport
extends ExtractionJobReport
implements JobReportWithChildren<DatabaseJobReport>

Report for JDBC and VDP jobs.

See Also:

• Serialized Form

Field Summary

Fields

Modifier and Type	Field	Description
protected Map<Integer,DatabaseJobReport>	reports	Map of Reports <int execution, DatabaseJobReport report> : holds the reports of the execution of each individual query if the the job has a parameterized query.

Fields inherited from class com.denodo.scheduler.client.job.report.AbstractExtractionJobReport

extractedDocs, extractorErrorsCount, extractorWarningsCount, maxErrorsToSave

Fields inherited from class com.denodo.scheduler.client.job.report.BaseJobReport

readWriteLock

Constructor Summary

Constructors

Constructor	Description
DatabaseJobReport()
DatabaseJobReport(int jobID, String jobName, String jobType, Date startTime, String query)

Method Summary

Modifier and Type	Method	Description
void	addExecutionSucess(Integer execution)
void	addExporterError(int execution, String exporterID, String errorDescription)
void	addExporterError(int execution, String exporterID, String errorDescription, boolean errorRetryable)
void	addExtractorError(int execution, String extractorError)
void	addExtractorWarning(int execution, String extractorWarning)
void	addReport(int execution, DatabaseJobReport report)
void	addSourceError(String error)
List<Object>	getCombinations()
List<Integer>	getExecutionErrors()
List<Integer>	getFailedExecutions()
String	getQuery()
Map<Integer,DatabaseJobReport>	getReports()
Collection<String>	getSourcesErrors()
List<Integer>	getSuccessExecutions()
boolean	hasErrors()
void	incExportedDocs(int execution, String exporterID, long numDocs)
void	incExtractedDocs(int execution, long numDocs)
void	removeReport(int execution)
void	reset()
void	setCombinations(List<Object> combinations)
void	setEndTime(int execution, Date date)
void	setPreviousExecutionErrors(List<Integer> previousExecutionErrors)
void	setPreviousExecutionSuccess(List<Integer> previousExecutionSuccess)
void	setQuery(String query)
String	toString()

Methods inherited from class com.denodo.scheduler.client.job.report.ExtractionJobReport

addExporterError, addExporterError, addExporterResource, addExporterResources, addExporterWarning, addExporterWithUnknownExportedTuples, containsRetryableErrors, getExportedDocs, getExporterErrors, getExporterErrorsCountByExporter, getExporterResources, getExporterResources, getExportersWithUnknownExportedTuples, getExporterWarnings, getExporterWarningsCountByExporter, getGlobalExportedDocs, hasRetryableExporterErrors, hasWarnings, incExportedDocs, setGlobalExportedDocs

Methods inherited from class com.denodo.scheduler.client.job.report.AbstractExtractionJobReport

addExtractorError, addExtractorWarning, getExtractedDocs, getExtractorErrors, getExtractorErrorsCount, getExtractorWarnings, getExtractorWarningsCount, getGlobalExtractedDocs, incExtractedDocs, setExtractedDocs, setExtractorErrors, setExtractorWarnings, setGlobalExtractedDocs

Methods inherited from class com.denodo.scheduler.client.job.report.BaseJobReport

addGeneralError, addGeneralWarning, addHandlerError, addHandlerWarning, addInitializationError, getDuration, getEndTime, getExtractionDataSourceName, getFirstTime, getGeneralErrors, getGeneralWarnings, getHandlerErrors, getHandlerWarnings, getId, getInitializationErrors, getJobID, getJobName, getJobType, getMisfireError, getProjectName, getRetryCount, getRetryJob, getServerInfo, getStartTime, hasMisfired, isInterrupted, setEndTime, setExtractionDataSourceName, setFirstTime, setId, setInterrupted, setJobID, setJobName, setJobType, setMisfireError, setProjectName, setRetryCount, setRetryJob, setServerInfo, setStartTime

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Field Details

reports

protected Map<Integer,DatabaseJobReport> reports

Map of Reports <int execution, DatabaseJobReport report> : holds the reports of the execution of each individual query if the the job has a parameterized query.

Constructor Details

DatabaseJobReport

public DatabaseJobReport()

DatabaseJobReport

public DatabaseJobReport(int jobID,
 String jobName,
 String jobType,
 Date startTime,
 String query)

Method Details

getQuery

public String getQuery()

setQuery

public void setQuery(String query)

getReports

public Map<Integer,DatabaseJobReport> getReports()

addReport

public void addReport(int execution,
 DatabaseJobReport report)

Specified by:

addReport in interface JobReportWithChildren<DatabaseJobReport>

removeReport

public void removeReport(int execution)

Specified by:

removeReport in interface JobReportWithChildren<DatabaseJobReport>

setEndTime

public void setEndTime(int execution,
 Date date)

Specified by:

setEndTime in interface JobReportWithChildren<DatabaseJobReport>

incExtractedDocs

public void incExtractedDocs(int execution,
 long numDocs)

Specified by:

incExtractedDocs in interface JobReportWithChildren<DatabaseJobReport>

addExtractorError

public void addExtractorError(int execution,
 String extractorError)

Specified by:

addExtractorError in interface JobReportWithChildren<DatabaseJobReport>

incExportedDocs

public void incExportedDocs(int execution,
 String exporterID,
 long numDocs)

addExporterError

public void addExporterError(int execution,
 String exporterID,
 String errorDescription)

addExporterError

public void addExporterError(int execution,
 String exporterID,
 String errorDescription,
 boolean errorRetryable)

getFailedExecutions

public List<Integer> getFailedExecutions()

setPreviousExecutionErrors

public void setPreviousExecutionErrors(List<Integer> previousExecutionErrors)

Parameters:

previousExecutionErrors - the previousExecutionErrors to set

getExecutionErrors

public List<Integer> getExecutionErrors()

Returns:

the executionErrors

addExecutionSucess

public void addExecutionSucess(Integer execution)

setPreviousExecutionSuccess

public void setPreviousExecutionSuccess(List<Integer> previousExecutionSuccess)

Parameters:

previousExecutionSuccess - the previousExecutionSuccess to set

getSuccessExecutions

public List<Integer> getSuccessExecutions()

getCombinations

public List<Object> getCombinations()

setCombinations

public void setCombinations(List<Object> combinations)

getSourcesErrors

public Collection<String> getSourcesErrors()

addSourceError

public void addSourceError(String error)

hasErrors

public boolean hasErrors()

Specified by:

hasErrors in interface JobReport

Overrides:

hasErrors in class ExtractionJobReport

reset

public void reset()

Specified by:

reset in interface JobReport

Specified by:

reset in interface JobReportWithChildren<DatabaseJobReport>

Overrides:

reset in class ExtractionJobReport

toString

public String toString()

Overrides:

toString in class ExtractionJobReport

addExtractorWarning

public void addExtractorWarning(int execution,
 String extractorWarning)

Specified by:

addExtractorWarning in interface JobReportWithChildren<DatabaseJobReport>