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

Class VDPDAGLoadJobReport

java.lang.Object

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

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

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

com.denodo.scheduler.client.job.report.VDPDAGLoadJobReport

All Implemented Interfaces:

JobReport, JobReportWithChildren<VDPDAGLoadJobReport>, Serializable

public class VDPDAGLoadJobReport
extends AbstractVDPLoadJobReport<VDPDAGLoadJobReport>

Report for VDP DAG Load jobs.

See Also:

• Serialized Form

Field Summary

Fields

Modifier and Type	Field	Description
static final String	CACHE
static final String	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
VDPDAGLoadJobReport()
VDPDAGLoadJobReport(int jobID, String jobName, String jobType, Date startTime, String query, String loadProcessType)
VDPDAGLoadJobReport(int jobID, String jobName, String jobType, Date startTime, String query, String loadProcessName, String loadProcessType)

Method Summary

Modifier and Type	Method	Description
void	addCacheError(int parent, int execution, String cacheError)
void	addCacheError(String cacheError)
protected void	addExtractorError(VDPDAGLoadJobReport report, int execution, String extractorError)
protected void	addExtractorError(VDPDAGLoadJobReport report, String extractorError)
protected void	addExtractorWarning(VDPDAGLoadJobReport report, int execution, String extractorWarning)
protected void	addExtractorWarning(VDPDAGLoadJobReport report, String extractorWarning)
void	addInsertError(int parent, int execution, String insertError)
void	addInsertError(int execution, String insertError)
void	addInsertError(String insertError)
protected void	addReport(VDPDAGLoadJobReport report, int execution, VDPDAGLoadJobReport reportToAdd)
boolean	containsRetryableErrors()
long	getCachedDocs()	Returns the number of cached documents.
Collection<Object>	getCacheErrors()	Returns the errors when caching tuples.
long	getCacheErrorsCount()
long	getGlobalCachedDocs()
long	getGlobalInsertedDocs()
long	getInsertedDocs()	Returns the number of inserted documents.
Collection<Object>	getInsertErrors()	Returns the errors when inserting tuples.
long	getInsertErrorsCount()
boolean	hasErrors()
boolean	hasTuplesNotCachedInQueriedView()
void	incCachedDocs(int parent, int execution, long numDocs)
void	incCachedDocs(long numDocs)
protected void	incExtractedDocs(VDPDAGLoadJobReport report, int execution, long numDocs)
protected void	incExtractedDocs(VDPDAGLoadJobReport report, long numDocs)
void	incInsertedDocs(int parent, int execution, long numDocs)
void	incInsertedDocs(int execution, long numDocs)
void	incInsertedDocs(long numDocs)
boolean	isCacheReport()
boolean	isSummaryReport()
protected void	removeReport(VDPDAGLoadJobReport report, int execution)
void	reset()
protected void	reset(VDPDAGLoadJobReport report)
protected void	setEndTime(VDPDAGLoadJobReport report, int execution, Date date)
protected void	setEndTime(VDPDAGLoadJobReport report, Date date)
void	setGlobalCachedDocs(long numDocs)
void	setGlobalInsertedDocs(long numDocs)
void	setTuplesNotCachedInQueriedView(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

Field Details

CACHE

public static final String CACHE

See Also:

• Constant Field Values

SUMMARY

public static final String SUMMARY

See Also:

• Constant Field Values

Constructor Details

VDPDAGLoadJobReport

public VDPDAGLoadJobReport()

VDPDAGLoadJobReport

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

VDPDAGLoadJobReport

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

Method Details

isCacheReport

public boolean isCacheReport()

isSummaryReport

public boolean isSummaryReport()

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)

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(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)

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)

getGlobalInsertedDocs

public long getGlobalInsertedDocs()

setGlobalInsertedDocs

public void setGlobalInsertedDocs(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)

hasErrors

public boolean hasErrors()

Specified by:

hasErrors in interface JobReport

Overrides:

hasErrors in class AbstractVDPLoadJobReport<VDPDAGLoadJobReport>

containsRetryableErrors

public boolean containsRetryableErrors()

Overrides:

containsRetryableErrors in class AbstractVDPLoadJobReport<VDPDAGLoadJobReport>

reset

public void reset()

Specified by:

reset in interface JobReport

Specified by:

reset in interface JobReportWithChildren<VDPDAGLoadJobReport>

Overrides:

reset in class AbstractVDPLoadJobReport<VDPDAGLoadJobReport>

toString

public String toString()

Overrides:

toString in class AbstractVDPLoadJobReport<VDPDAGLoadJobReport>

addReport

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

Specified by:

addReport in class AbstractVDPLoadJobReport<VDPDAGLoadJobReport>

removeReport

protected void removeReport(VDPDAGLoadJobReport report,
 int execution)

Specified by:

removeReport in class AbstractVDPLoadJobReport<VDPDAGLoadJobReport>

setEndTime

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

Specified by:

setEndTime in class AbstractVDPLoadJobReport<VDPDAGLoadJobReport>

setEndTime

protected void setEndTime(VDPDAGLoadJobReport report,
 Date date)

Specified by:

setEndTime in class AbstractVDPLoadJobReport<VDPDAGLoadJobReport>

incExtractedDocs

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

Specified by:

incExtractedDocs in class AbstractVDPLoadJobReport<VDPDAGLoadJobReport>

incExtractedDocs

protected void incExtractedDocs(VDPDAGLoadJobReport report,
 long numDocs)

Specified by:

incExtractedDocs in class AbstractVDPLoadJobReport<VDPDAGLoadJobReport>

addExtractorError

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

Specified by:

addExtractorError in class AbstractVDPLoadJobReport<VDPDAGLoadJobReport>

addExtractorError

protected void addExtractorError(VDPDAGLoadJobReport report,
 String extractorError)

Specified by:

addExtractorError in class AbstractVDPLoadJobReport<VDPDAGLoadJobReport>

addExtractorWarning

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

Specified by:

addExtractorWarning in class AbstractVDPLoadJobReport<VDPDAGLoadJobReport>

addExtractorWarning

protected void addExtractorWarning(VDPDAGLoadJobReport report,
 String extractorWarning)

Specified by:

addExtractorWarning in class AbstractVDPLoadJobReport<VDPDAGLoadJobReport>

reset

protected void reset(VDPDAGLoadJobReport report)

Specified by:

reset in class AbstractVDPLoadJobReport<VDPDAGLoadJobReport>