com.denodo.scheduler.client.job.report

Class VDPDataLoadJobReport

java.lang.Object

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

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

com.denodo.scheduler.client.job.report.VDPDataLoadJobReport

All Implemented Interfaces:

JobReport, Serializable

public class VDPDataLoadJobReport
extends AbstractExtractionJobReport

Report for VDP Data Load jobs.

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
VDPDataLoadJobReport()
VDPDataLoadJobReport(int jobID, String jobName, String jobType, Date startTime, String query)
VDPDataLoadJobReport(int jobID, String jobName, String jobType, Date startTime, String query, String loadProcessName)

Method Summary

Modifier and Type	Method and Description
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	addInsertError(int parent, int execution, String insertError)
void	addInsertError(int execution, String insertError)
void	addInsertError(String insertError)
void	addReport(int parent, int execution, VDPDataLoadJobReport reportToAdd)
void	addReport(int execution, VDPDataLoadJobReport report)
boolean	containsRetryableErrors()
Map<Integer,List<Integer>>	getFailedExecutions()
long	getInsertedDocs() Returns the number of inserted documents.
Collection<Object>	getInsertErrors() Returns the errors when inserting tuples.
long	getInsertErrorsCount()
String	getLoadProcessName() Gets the name of the load process to preload a VDP view.
String	getQuery() Gets the executed query.
Map<Integer,VDPDataLoadJobReport>	getReports()
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()
void	incExtractedDocs(int parent, int execution, long numDocs)
void	incExtractedDocs(int execution, long numDocs)
void	incInsertedDocs(int parent, int execution, long numDocs)
void	incInsertedDocs(int execution, long numDocs)
void	incInsertedDocs(long numDocs)
void	removeReport(int execution)
void	removeReport(int parent, int execution)
void	reset()
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)
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, 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

Field Detail

serialVersionUID

protected static final long serialVersionUID

For interoperability with possible future changes.

See Also:

Constant Field Values

Constructor Detail

VDPDataLoadJobReport

public VDPDataLoadJobReport()

VDPDataLoadJobReport

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

VDPDataLoadJobReport

public VDPDataLoadJobReport(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) execute parameterized not parameterized queries.

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,VDPDataLoadJobReport> getReports()

addReport

public void addReport(int execution,
                      VDPDataLoadJobReport report)

addReport

public void addReport(int parent,
                      int execution,
                      VDPDataLoadJobReport 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)

getInsertErrorsCount

public long getInsertErrorsCount()

getInsertedDocs

public long getInsertedDocs()

Returns the number of inserted documents.

incInsertedDocs

public void incInsertedDocs(long numDocs)

incInsertedDocs

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

incInsertedDocs

public void incInsertedDocs(int execution,
                            long numDocs)

getInsertErrors

public Collection<Object> getInsertErrors()

Returns the errors when inserting tuples.

Returns:

The collection of errors

addInsertError

public void addInsertError(String insertError)

addInsertError

public void addInsertError(int parent,
                           int execution,
                           String insertError)

addInsertError

public void addInsertError(int execution,
                           String insertError)

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

getSuccessExecutions

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

Returns the successful executions, by load process.

getFailedExecutions

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

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