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

Class VDPCacheJobReport

java.lang.Object

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

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

com.denodo.scheduler.client.job.report.AbstractVDPLoadJobReport<VDPCacheJobReport>

com.denodo.scheduler.client.job.report.VDPCacheJobReport

All Implemented Interfaces:

JobReport, JobReportWithChildren<VDPCacheJobReport>, Serializable

public class VDPCacheJobReport
extends AbstractVDPLoadJobReport<VDPCacheJobReport>

Report for VDP Cache jobs.

Since:

5.0

See Also:

• Serialized Form

Field Summary

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

executionErrors, executionSuccess, executionWarnings, loadProcessName, previousExecutionErrors, previousExecutionSuccess, query, 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
VDPCacheJobReport()
VDPCacheJobReport(int jobID, String jobName, String jobType, Date startTime, String query)
VDPCacheJobReport(int jobID, String jobName, String jobType, Date startTime, String query, String loadProcessName)

Method Summary

Modifier and Type	Method	Description
void	addCacheError(int parent, int execution, String cacheError)
void	addCacheError(int execution, String cacheError)
void	addCacheError(String cacheError)
protected void	addExtractorError(VDPCacheJobReport report, int execution, String extractorError)
protected void	addExtractorError(VDPCacheJobReport report, String extractorError)
protected void	addExtractorWarning(VDPCacheJobReport report, int execution, String extractorWarning)
protected void	addExtractorWarning(VDPCacheJobReport report, String extractorWarning)
protected void	addReport(VDPCacheJobReport report, int execution, VDPCacheJobReport reportToAdd)
void	addSourceError(int parent, String sourceError)
void	addSourceError(String sourceError)
boolean	containsRetryableErrors()
long	getCachedDocs()	Returns the number of cached documents.
Collection<Object>	getCacheErrors()	Returns the errors when caching tuples.
long	getCacheErrorsCount()
Map<Integer,List<Object>>	getCombinations()	Returns the list of queries combinations (values of the parameters of a parameterized query), grouped by load process.
List<Object>	getCombinations(Integer execution)	Returns the combinations of a load process.
long	getGlobalCachedDocs()
Collection<String>	getSourcesErrors()
boolean	hasErrors()
boolean	hasTuplesNotCachedInQueriedView()
void	incCachedDocs(int parent, int execution, long numDocs)
void	incCachedDocs(int execution, long numDocs)
void	incCachedDocs(long numDocs)
protected void	incExtractedDocs(VDPCacheJobReport report, int execution, long numDocs)
protected void	incExtractedDocs(VDPCacheJobReport report, long numDocs)
protected void	removeReport(VDPCacheJobReport report, int execution)
void	reset()
protected void	reset(VDPCacheJobReport report)
void	setCombinations(Integer execution, List<Object> combinations)
void	setCombinations(Map<Integer,List<Object>> combinations)
protected void	setEndTime(VDPCacheJobReport report, int execution, Date date)
protected void	setEndTime(VDPCacheJobReport report, Date date)
void	setGlobalCachedDocs(long numDocs)
void	setTuplesNotCachedInQueriedView(boolean tuplesNotCachedInQueriedView)
void	setTuplesNotCachedInQueriedView(int execution, boolean tuplesNotCachedInQueriedView)
void	setTuplesNotCachedInQueriedView(int parent, int execution, boolean tuplesNotCachedInQueriedView)
String	toString()

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

addExecutionSucess, addExtractorError, addExtractorError, addExtractorWarning, addExtractorWarning, addLoadProcessSuccess, addReport, addReport, getFailedExecutions, getLoadProcessName, getLoadProcessSuccess, getQuery, getReports, getSuccessExecutions, getSuccessExecutions, incExtractedDocs, incExtractedDocs, removeReport, removeReport, setEndTime, setEndTime, setLoadProcessName, setPreviousExecutionErrors, setPreviousExecutionSuccess, setPreviousLoadProcessSuccess, setQuery

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

addExtractorError, addExtractorWarning, getExtractedDocs, getExtractorErrors, getExtractorErrorsCount, getExtractorWarnings, getExtractorWarningsCount, getGlobalExtractedDocs, hasWarnings, 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

Constructor Details

VDPCacheJobReport

public VDPCacheJobReport()

VDPCacheJobReport

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

VDPCacheJobReport

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

Method Details

getCacheErrorsCount

public long getCacheErrorsCount()

getCachedDocs

public long getCachedDocs()

Returns the number of cached documents.

incCachedDocs

public void incCachedDocs(long numDocs)

incCachedDocs

public void incCachedDocs(int parent,
 int execution,
 long numDocs)

incCachedDocs

public void incCachedDocs(int execution,
 long numDocs)

setGlobalCachedDocs

public void setGlobalCachedDocs(long numDocs)

getGlobalCachedDocs

public long getGlobalCachedDocs()

hasTuplesNotCachedInQueriedView

public boolean hasTuplesNotCachedInQueriedView()

Returns:

true if the tuples have not been cached in the queried view.

setTuplesNotCachedInQueriedView

public void setTuplesNotCachedInQueriedView(int parent,
 int execution,
 boolean tuplesNotCachedInQueriedView)

setTuplesNotCachedInQueriedView

public void setTuplesNotCachedInQueriedView(int execution,
 boolean tuplesNotCachedInQueriedView)

setTuplesNotCachedInQueriedView

public void setTuplesNotCachedInQueriedView(boolean tuplesNotCachedInQueriedView)

getCacheErrors

public Collection<Object> getCacheErrors()

Returns the errors when caching tuples.

Returns:

The collection of errors

addCacheError

public void addCacheError(String cacheError)

addCacheError

public void addCacheError(int parent,
 int execution,
 String cacheError)

addCacheError

public void addCacheError(int execution,
 String cacheError)

getCombinations

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

Returns the list of queries combinations (values of the parameters of a parameterized query), grouped by load process. Used to store the combinations and not to retrieve the values from sources when the job is retried or started with state.

getCombinations

public List<Object> getCombinations(Integer execution)

Returns the combinations of a load process.

Parameters:

execution - the load process identifier

Returns:

the list of values

setCombinations

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

setCombinations

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

getSourcesErrors

public Collection<String> getSourcesErrors()

addSourceError

public void addSourceError(String sourceError)

addSourceError

public void addSourceError(int parent,
 String sourceError)

hasErrors

public boolean hasErrors()

Specified by:

hasErrors in interface JobReport

Overrides:

hasErrors in class AbstractVDPLoadJobReport<VDPCacheJobReport>

containsRetryableErrors

public boolean containsRetryableErrors()

Overrides:

containsRetryableErrors in class AbstractVDPLoadJobReport<VDPCacheJobReport>

reset

public void reset()

Specified by:

reset in interface JobReport

Specified by:

reset in interface JobReportWithChildren<VDPCacheJobReport>

Overrides:

reset in class AbstractVDPLoadJobReport<VDPCacheJobReport>

toString

public String toString()

Overrides:

toString in class AbstractVDPLoadJobReport<VDPCacheJobReport>

addReport

protected void addReport(VDPCacheJobReport report,
 int execution,
 VDPCacheJobReport reportToAdd)

Specified by:

addReport in class AbstractVDPLoadJobReport<VDPCacheJobReport>

removeReport

protected void removeReport(VDPCacheJobReport report,
 int execution)

Specified by:

removeReport in class AbstractVDPLoadJobReport<VDPCacheJobReport>

setEndTime

protected void setEndTime(VDPCacheJobReport report,
 int execution,
 Date date)

Specified by:

setEndTime in class AbstractVDPLoadJobReport<VDPCacheJobReport>

setEndTime

protected void setEndTime(VDPCacheJobReport report,
 Date date)

Specified by:

setEndTime in class AbstractVDPLoadJobReport<VDPCacheJobReport>

incExtractedDocs

protected void incExtractedDocs(VDPCacheJobReport report,
 int execution,
 long numDocs)

Specified by:

incExtractedDocs in class AbstractVDPLoadJobReport<VDPCacheJobReport>

incExtractedDocs

protected void incExtractedDocs(VDPCacheJobReport report,
 long numDocs)

Specified by:

incExtractedDocs in class AbstractVDPLoadJobReport<VDPCacheJobReport>

addExtractorError

protected void addExtractorError(VDPCacheJobReport report,
 int execution,
 String extractorError)

Specified by:

addExtractorError in class AbstractVDPLoadJobReport<VDPCacheJobReport>

addExtractorError

protected void addExtractorError(VDPCacheJobReport report,
 String extractorError)

Specified by:

addExtractorError in class AbstractVDPLoadJobReport<VDPCacheJobReport>

addExtractorWarning

protected void addExtractorWarning(VDPCacheJobReport report,
 int execution,
 String extractorWarning)

Specified by:

addExtractorWarning in class AbstractVDPLoadJobReport<VDPCacheJobReport>

addExtractorWarning

protected void addExtractorWarning(VDPCacheJobReport report,
 String extractorWarning)

Specified by:

addExtractorWarning in class AbstractVDPLoadJobReport<VDPCacheJobReport>

reset

protected void reset(VDPCacheJobReport report)

Specified by:

reset in class AbstractVDPLoadJobReport<VDPCacheJobReport>