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

Class VDPIndexerJobReport

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

com.denodo.scheduler.client.job.report.VDPIndexerJobReport

All Implemented Interfaces:

JobReport, Serializable

public class VDPIndexerJobReport
extends DatabaseJobReport

Report for VDPIndexer jobs.

See Also:

• Serialized Form

Field Summary

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

reports

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
VDPIndexerJobReport()
VDPIndexerJobReport(int jobID, String jobName, String jobType, Date startTime, long extractedRows)

Method Summary

Modifier and Type	Method	Description
void	addExecutionSucess(Integer parent, Integer execution)
void	addExporterError(int taskId, int execution, String exporterID, String errorDescription)
void	addExporterError(int taskId, int execution, String exporterID, String errorDescription, boolean errorRetryable)
void	addExporterWithUnknownExportedTuples(int taskId, String exporterID)
void	addExtractorError(int taskId, int execution, String extractorError)
void	addSourceError(int taskId, String sourceError)
void	addViewWithNonSatisfiedMandatoryRestrictionsError(String view, String error)
Map<Integer,List<Object>>	getAggregatedCombinations()
Map<Integer,List<Object>>	getAggregatedCombinations(boolean cloneCombinations)
Map<Integer,List<Integer>>	getAggregatedFailedExecutions()
Map<Integer,List<Integer>>	getAggregatedSuccessExecutions()
long	getExtractedRows()
Map<String,String>	getViewsWithNonSatisfiedMandatoryRestrictionsErrors()
boolean	hasErrors()
void	incExportedDocs(int taskId, int execution, String exporterID, long numDocs)
void	incExtractedDocs(int taskId, int execution, long numDocs)
void	incExtractedRows(int taskId, int execution, long numRows)
void	removeReport(int parent, int execution)
void	reset()
void	setAggregateCombinations(Map<Integer,List<Object>> combinations)
void	setAggregatePreviousExecutionErrors(Map<Integer,List<Integer>> previousExecutionErrors)
void	setAggregatePreviousExecutionSuccess(Map<Integer,List<Integer>> previousExecutionSuccess)
void	setCombinations(Integer taskId, List<Object> combinations)
void	setEndTime(int parent, int execution, Date date)
void	setExtractedRows(long extractedRows)
void	setViewsWithNonSatisfiedMandatoryRestrictionsErrors(Map<String,String> viewsWithNonSatisfiedMandatoryRestrictionsErrors)
String	toString()

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

addExecutionSucess, addExporterError, addExporterError, addExtractorError, addReport, addSourceError, getCombinations, getExecutionErrors, getFailedExecutions, getQuery, getReports, getSourcesErrors, getSuccessExecutions, incExportedDocs, incExtractedDocs, removeReport, setCombinations, setEndTime, setPreviousExecutionErrors, setPreviousExecutionSuccess, setQuery

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, hasRetryableExporterErrors, hasWarnings, incExportedDocs

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

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

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

addGeneralError, addGeneralWarning, addHandlerError, addHandlerWarning, addInitializationError, 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

Constructor Details

VDPIndexerJobReport

public VDPIndexerJobReport()

VDPIndexerJobReport

public VDPIndexerJobReport(int jobID,
 String jobName,
 String jobType,
 Date startTime,
 long extractedRows)

Method Details

getAggregatedCombinations

public Map<Integer,List<Object>> getAggregatedCombinations(boolean cloneCombinations)

getAggregatedCombinations

public Map<Integer,List<Object>> getAggregatedCombinations()

setCombinations

public void setCombinations(Integer taskId,
 List<Object> combinations)

setAggregateCombinations

public void setAggregateCombinations(Map<Integer,List<Object>> combinations)

getExtractedRows

public long getExtractedRows()

setExtractedRows

public void setExtractedRows(long extractedRows)

getViewsWithNonSatisfiedMandatoryRestrictionsErrors

public Map<String,String> getViewsWithNonSatisfiedMandatoryRestrictionsErrors()

setViewsWithNonSatisfiedMandatoryRestrictionsErrors

public void setViewsWithNonSatisfiedMandatoryRestrictionsErrors(Map<String,String> viewsWithNonSatisfiedMandatoryRestrictionsErrors)

incExtractedRows

public void incExtractedRows(int taskId,
 int execution,
 long numRows)

incExtractedDocs

public void incExtractedDocs(int taskId,
 int execution,
 long numDocs)

incExportedDocs

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

addExecutionSucess

public void addExecutionSucess(Integer parent,
 Integer execution)

addViewWithNonSatisfiedMandatoryRestrictionsError

public void addViewWithNonSatisfiedMandatoryRestrictionsError(String view,
 String error)

addExporterWithUnknownExportedTuples

public void addExporterWithUnknownExportedTuples(int taskId,
 String exporterID)

addExporterError

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

addExporterError

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

addExtractorError

public void addExtractorError(int taskId,
 int execution,
 String extractorError)

addSourceError

public void addSourceError(int taskId,
 String sourceError)

setAggregatePreviousExecutionSuccess

public void setAggregatePreviousExecutionSuccess(Map<Integer,List<Integer>> previousExecutionSuccess)

setAggregatePreviousExecutionErrors

public void setAggregatePreviousExecutionErrors(Map<Integer,List<Integer>> previousExecutionErrors)

getAggregatedSuccessExecutions

public Map<Integer,List<Integer>> getAggregatedSuccessExecutions()

getAggregatedFailedExecutions

public Map<Integer,List<Integer>> getAggregatedFailedExecutions()

setEndTime

public void setEndTime(int parent,
 int execution,
 Date date)

removeReport

public void removeReport(int parent,
 int execution)

hasErrors

public boolean hasErrors()

Specified by:

hasErrors in interface JobReport

Overrides:

hasErrors in class DatabaseJobReport

reset

public void reset()

Specified by:

reset in interface JobReport

Overrides:

reset in class DatabaseJobReport

toString

public String toString()

Overrides:

toString in class DatabaseJobReport