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.VDPCacheJobReport

All Implemented Interfaces:

JobReport, Serializable

public class VDPCacheJobReport
extends AbstractExtractionJobReport

Report for VDP Cache jobs.

Since:

5.0

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field and Description
protected static long	serialVersionUID For interoperability with possible future changes.

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 and 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 and Description
void	addCacheError(int parent, int execution, String cacheError)
void	addCacheError(int execution, String cacheError)
void	addCacheError(String cacheError)
void	addExecutionSucess(Integer parent, Integer execution)
void	addExtractorError(int taskId, int execution, String extractorError)
void	addExtractorError(int execution, String extractorError)
void	addExtractorWarning(int taskId, int execution, String extractorWarning)
void	addExtractorWarning(int execution, String extractorWarning)
void	addReport(int parent, int execution, VDPCacheJobReport reportToAdd)
void	addReport(int execution, VDPCacheJobReport report)
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.
Map<Integer,List<Integer>>	getFailedExecutions()
String	getLoadProcessName() Gets the name of the load process to preload a VDP view.
String	getQuery() Gets the executed query.
Map<Integer,VDPCacheJobReport>	getReports()
Collection<String>	getSourcesErrors()
Map<Integer,List<Integer>>	getSuccessExecutions() Returns the successful executions, by load process.
List<Integer>	getSuccessExecutions(int parent) Returns the successful executions of a load process.
boolean	hasErrors()
boolean	hasTuplesNotCachedInQueriedView()
void	incCachedDocs(int parent, int execution, long numDocs)
void	incCachedDocs(int execution, long numDocs)
void	incCachedDocs(long numDocs)
void	incExtractedDocs(int parent, int execution, long numDocs)
void	incExtractedDocs(int execution, long numDocs)
void	removeReport(int execution)
void	removeReport(int parent, int execution)
void	reset()
void	setCombinations(Integer execution, List<Object> combinations)
void	setCombinations(Map<Integer,List<Object>> combinations)
void	setEndTime(int execution, Date date)
void	setEndTime(int parent, int execution, Date date)
void	setLoadProcessName(String loadProcessName)
void	setPreviousExecutionErrors(Map<Integer,List<Integer>> previousExecutionErrors)
void	setPreviousExecutionSuccess(Map<Integer,List<Integer>> previousExecutionSuccess)
void	setQuery(String query)
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.AbstractExtractionJobReport

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

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

addGeneralError, addGeneralWarning, addHandlerError, addInitializationError, getEndTime, getExtractionDataSourceName, getFirstTime, getGeneralErrors, getGeneralWarnings, getHandlerErrors, getId, getInitializationErrors, getJobID, getJobName, getJobType, getMisfireError, getProjectName, getRetryCount, getRetryJob, getServerInfo, getStartTime, hasMisfired, setEndTime, setExtractionDataSourceName, setFirstTime, setId, 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 Detail

serialVersionUID

protected static final long serialVersionUID

For interoperability with possible future changes.

See Also:

Constant Field Values

Constructor Detail

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 Detail

getQuery

public String getQuery()

Gets the executed query. Considerations:

• The top level report (the job's one) does not execute any query.
• The second level reports (load processes' ones) may execute parameterized or not parameterized queries. In the first case, they have third level reports.
• The third level reports only exist if the load process they belong to have a parameterized query. It represents the exact query against VDP.

Returns:

the query

setQuery

public void setQuery(String query)

getLoadProcessName

public String getLoadProcessName()

Gets the name of the load process to preload a VDP view. Only for load processes reports (second level ones).

Returns:

the load process name

setLoadProcessName

public void setLoadProcessName(String loadProcessName)

getReports

public Map<Integer,VDPCacheJobReport> getReports()

addReport

public void addReport(int execution,
                      VDPCacheJobReport report)

addReport

public void addReport(int parent,
                      int execution,
                      VDPCacheJobReport reportToAdd)

removeReport

public void removeReport(int execution)

removeReport

public void removeReport(int parent,
                         int execution)

setEndTime

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

setEndTime

public void setEndTime(int execution,
                       Date date)

incExtractedDocs

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

incExtractedDocs

public void incExtractedDocs(int execution,
                             long numDocs)

addExtractorError

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

addExtractorError

public void addExtractorError(int execution,
                              String extractorError)

addExtractorWarning

public void addExtractorWarning(int taskId,
                                int execution,
                                String extractorWarning)

addExtractorWarning

public void addExtractorWarning(int execution,
                                String extractorWarning)

getCacheErrorsCount

public long getCacheErrorsCount()

getCachedDocs

public long getCachedDocs()

Returns the number of cached documents.

Returns:

incCachedDocs

public void incCachedDocs(long numDocs)

incCachedDocs

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

incCachedDocs

public void incCachedDocs(int execution,
                          long numDocs)

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)

setPreviousExecutionSuccess

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

Parameters:

previousExecutionSuccess - the previousExecutionSuccess to set

setPreviousExecutionErrors

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

Parameters:

previousExecutionErrors - the previousExecutionErrors to set

addExecutionSucess

public void addExecutionSucess(Integer parent,
                               Integer execution)

getSuccessExecutions

public List<Integer> getSuccessExecutions(int parent)

Returns the successful executions of a load process.

Parameters:

parent - the load process identifier

Returns:

getSuccessExecutions

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

Returns the successful executions, by load process.

Returns:

getFailedExecutions

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

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.

Returns:

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 AbstractExtractionJobReport

containsRetryableErrors

public boolean containsRetryableErrors()

Overrides:

containsRetryableErrors in class AbstractExtractionJobReport

reset

public void reset()

Specified by:

reset in interface JobReport

Overrides:

reset in class AbstractExtractionJobReport

toString

public String toString()

Overrides:

toString in class AbstractExtractionJobReport