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

Class AbstractVDPLoadJobReport<ReportType>

java.lang.Object
com.denodo.scheduler.client.job.report.BaseJobReport
com.denodo.scheduler.client.job.report.AbstractExtractionJobReport
com.denodo.scheduler.client.job.report.AbstractVDPLoadJobReport<ReportType>
All Implemented Interfaces:
JobReport, JobReportWithChildren<ReportType>, Serializable
Direct Known Subclasses:
VDPCacheJobReport, VDPDAGLoadJobReport, VDPDataLoadJobReport
public abstract class AbstractVDPLoadJobReport<ReportType> extends AbstractExtractionJobReport implements JobReportWithChildren<ReportType>
Report for common data used in VDP Cache and DataLoad jobs.
See Also:

  • Field Details

    • query

      protected String query

    • loadProcessName

      protected String loadProcessName

    • executionSuccess

      protected Map<Integer,List<Integer>> executionSuccess
      List of identifiers of current executions that finished successfully, grouped by load process.

    • executionErrors

      protected Map<Integer,List<Integer>> executionErrors
      List of identifiers of current executions that finished with error, grouped by load process.

    • executionWarnings

      protected Map<Integer,List<Integer>> executionWarnings
      List of identifiers of current executions that finished with warning, grouped by load process.

    • previousExecutionErrors

      protected Map<Integer,List<Integer>> previousExecutionErrors
      List of identifiers of previous executions that finished with error, grouped by load process.

    • previousExecutionSuccess

      protected Map<Integer,List<Integer>> previousExecutionSuccess
      List of identifiers of previous executions that finished successfully, grouped by load process.

    • reports

      protected Map<Integer,ReportType> reports
      Map of Reports <int loadProcess, VDPAbstractLoadJobReport report> : holds the reports of the execution of each individual load process.

  • Constructor Details

    • AbstractVDPLoadJobReport

      protected AbstractVDPLoadJobReport()

    • AbstractVDPLoadJobReport

      protected AbstractVDPLoadJobReport(int jobID, String jobName, String jobType, Date startTime, String query)

    • AbstractVDPLoadJobReport

      protected AbstractVDPLoadJobReport(int jobID, String jobName, String jobType, Date startTime, String query, String loadProcessName)

  • Method Details

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

    • addReport

      public void addReport(int execution, ReportType report)
      Specified by:
      addReport in interface JobReportWithChildren<ReportType>

    • addReport

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

    • addReport

      protected abstract void addReport(ReportType report, int execution, ReportType reportToAdd)

    • removeReport

      public void removeReport(int execution)
      Specified by:
      removeReport in interface JobReportWithChildren<ReportType>

    • removeReport

      public void removeReport(int parent, int execution)

    • removeReport

      protected abstract void removeReport(ReportType report, int execution)

    • setEndTime

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

    • setEndTime

      protected abstract void setEndTime(ReportType report, int execution, Date date)

    • setEndTime

      public void setEndTime(int execution, Date date)
      Specified by:
      setEndTime in interface JobReportWithChildren<ReportType>

    • setEndTime

      protected abstract void setEndTime(ReportType report, Date date)

    • incExtractedDocs

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

    • incExtractedDocs

      protected abstract void incExtractedDocs(ReportType report, int execution, long numDocs)

    • incExtractedDocs

      public void incExtractedDocs(int execution, long numDocs)
      Specified by:
      incExtractedDocs in interface JobReportWithChildren<ReportType>

    • incExtractedDocs

      protected abstract void incExtractedDocs(ReportType report, long numDocs)

    • addExtractorError

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

    • addExtractorError

      protected abstract void addExtractorError(ReportType report, int execution, String extractorError)

    • addExtractorError

      public void addExtractorError(int execution, String extractorError)
      Specified by:
      addExtractorError in interface JobReportWithChildren<ReportType>

    • addExtractorError

      protected abstract void addExtractorError(ReportType report, String extractorError)

    • addExtractorWarning

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

    • addExtractorWarning

      protected abstract void addExtractorWarning(ReportType report, int execution, String extractorWarning)

    • addExtractorWarning

      public void addExtractorWarning(int execution, String extractorWarning)
      Specified by:
      addExtractorWarning in interface JobReportWithChildren<ReportType>

    • addExtractorWarning

      protected abstract void addExtractorWarning(ReportType report, String extractorWarning)

    • 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
      Specified by:
      reset in interface JobReportWithChildren<ReportType>
      Overrides:
      reset in class AbstractExtractionJobReport

    • reset

      protected abstract void reset(ReportType report)

    • addLoadProcessSuccess

      public void addLoadProcessSuccess(LoadProcessSuccessInfo info)

    • setPreviousLoadProcessSuccess

      public void setPreviousLoadProcessSuccess(Map<String,LoadProcessSuccessInfo> previousLoadProcessSuccess)

    • getLoadProcessSuccess

      public Map<String,LoadProcessSuccessInfo> getLoadProcessSuccess()

    • toString

      public String toString()
      Overrides:
      toString in class AbstractExtractionJobReport