Package com.denodo.scheduler.client.job

Class JobData

java.lang.Object
com.denodo.scheduler.client.job.JobData
All Implemented Interfaces:
Serializable
Direct Known Subclasses:
VDPCacheJobData, VDPDataLoadJobData, VDPIndexerJobData
public class JobData extends Object implements Serializable
Information about a job in the scheduler: its name, current status, last execution and its last results.
See Also:

  • Field Details

    • serialVersionUID

      protected static final long serialVersionUID
      For interoperability with possible future changes.
      See Also:

  • Constructor Details

    • JobData

      public JobData()

    • JobData

      public JobData(int jobID, String name, String type)

    • JobData

      public JobData(JobData jobData)

  • Method Details

    • getJobID

      public int getJobID()

    • getProjectName

      public String getProjectName()
      Returns:
      the projectName

    • setProjectName

      public void setProjectName(String name)
      Parameters:
      name - the project name to set

    • getProjectId

      public int getProjectId()
      Returns:
      the projectId

    • setProjectId

      public void setProjectId(int projectId)
      Parameters:
      projectId - the project projectId to set

    • getName

      public String getName()
      Returns:
      the name

    • setName

      public void setName(String name)
      Parameters:
      name - the name to set

    • getType

      public String getType()
      Returns:
      the type

    • setType

      public void setType(String type)
      Parameters:
      type - the type to set

    • getState

      public JobData.State getState()
      Returns:
      the status

    • setState

      public void setState(JobData.State state)
      Parameters:
      state - the state to set

    • getLastResult

      public JobData.Result getLastResult()
      Returns:
      the lastResult

    • setLastResult

      public void setLastResult(JobData.Result lastResult)
      Parameters:
      lastResult - the lastResult to set

    • getFirstExecution

      public long getFirstExecution()
      Returns the first time in milliseconds at which the job was fire. If the job has not yet fired, null will be returned. Re-executions because of a 'retry' situation are not considered.
      Returns:
      the previousExecution

    • setFirstExecution

      public void setFirstExecution(long firstExecution)
      Sets the first time in milliseconds at which the job was fire. Re-executions because of a 'retry' situation are not considered.
      Parameters:
      firstExecution - the firstExecution to set

    • getPreviousExecution

      public Date getPreviousExecution()
      Returns the previous time at which the job will fire. If the job has not yet fired, null will be returned.
      Returns:
      the previousExecution

    • setPreviousExecution

      public void setPreviousExecution(Date previousExecution)
      Sets the previous time at which the job will fire.
      Parameters:
      previousExecution - the previousExecution to set

    • getNextExecution

      public Date getNextExecution()
      Returns the next time at which the job will fire. If the job will not fire again, null will be returned.
      Returns:
      the nextExecution

    • setNextExecution

      public void setNextExecution(Date nextExecution)
      Sets the next time at which the job will fire. If the job will not fire again, it will be set to null.
      Parameters:
      nextExecution - the nextExecution to set

    • getExtractionResult

      public long getExtractionResult()
      Returns:
      the extractionResult

    • incExtractionResult

      public void incExtractionResult(long num)

    • getExtractionGlobalResult

      public long getExtractionGlobalResult()
      Returns:
      the extractionGlobalResult

    • incExtractionGlobalResult

      public void incExtractionGlobalResult(long num)

    • getExtractionErrors

      public long getExtractionErrors()
      Returns:
      the extractionErrors

    • incExtractionErrors

      public void incExtractionErrors(long num)

    • getExtractionWarnings

      public long getExtractionWarnings()
      Returns:
      the extractionWarnings

    • incExtractionWarnings

      public void incExtractionWarnings(long num)

    • getExportationResult

      public Map<String,Long> getExportationResult()
      Returns:
      the exportationResult

    • setExportationResult

      public void setExportationResult(Map<String,Long> exportationResult)

    • incExportationResult

      public void incExportationResult(String exporterID, long num)

    • getExportationGlobalResult

      public Map<String,Long> getExportationGlobalResult()
      Returns:
      the exportationGlobalResult

    • setExportationGlobalResult

      public void setExportationGlobalResult(Map<String,Long> exportationGlobalResult)

    • incExportationGlobalResult

      public void incExportationGlobalResult(String exporterID, long num)

    • getExportationErrors

      public Map<String,Long> getExportationErrors()
      Returns:
      the exportationErrors

    • setExportationErrors

      public void setExportationErrors(Map<String,Long> exportationErrors)

    • incExportationErrors

      public void incExportationErrors(String exporterID, long num)

    • getExportationWarnings

      public Map<String,Long> getExportationWarnings()
      Returns:
      the exportationWarnings

    • setExportationWarnings

      public void setExportationWarnings(Map<String,Long> exportationWarnings)

    • incExportationWarnings

      public void incExportationWarnings(String exporterID, long num)

    • getParametersExecuted

      public long getParametersExecuted()
      Returns:
      the parametersExecuted

    • incParametersExecuted

      public void incParametersExecuted(long num)

    • getExportersWithUnknownExportedTuples

      public Set<String> getExportersWithUnknownExportedTuples()
      Returns the list of exporter names which may have exported more than the tuples indicated in getExportationResult(). Related to batch inserts in JDBCExporters.

    • addExporterWithUnknownExportedTuples

      public void addExporterWithUnknownExportedTuples(String exporterName)

    • getQueryErrors

      public Serializable getQueryErrors()
      Gets the queries which returned an error (for retrying them if needed).
      Returns:
      In the case of VDPCache jobs, a Map<Integer, List<Integer>>; otherwise, a List<Integer>.

    • setQueryErrors

      public void setQueryErrors(Serializable queryErrors)

    • getQuerySuccess

      public Serializable getQuerySuccess()
      Gets the queries which did not returned an error (for not retrying them).
      Returns:
      In the case of VDPCache jobs, a Map<Integer, List<Integer>>; otherwise, a List<Integer>.

    • setQuerySuccess

      public void setQuerySuccess(Serializable querySuccess)

    • getRetryCount

      public int getRetryCount()

    • setRetryCount

      public void setRetryCount(int retryCount)

    • retryJob

      public boolean retryJob()

    • setRetryJob

      public void setRetryJob(boolean retryJob)

    • isInterrupted

      public boolean isInterrupted()

    • setInterrupted

      public void setInterrupted(boolean interrupted)

    • getCombinations

      public Serializable getCombinations()
      Gets the values of the parameters of a parameterized query (in order to not query the sources when retrying a job).
      Returns:
      In the case of VDPCache jobs, a Map<Integer, List<Serializable>>; otherwise, a List<Serializable>.

    • setCombinations

      public void setCombinations(Serializable combinations)

    • reset

      public void reset()

    • isStartedWithState

      public boolean isStartedWithState()

    • setStartedWithState

      public void setStartedWithState(boolean startedWithState)

    • completeJobData

      public boolean completeJobData(JobReport jobReport)

    • toString

      public String toString()
      Overrides:
      toString in class Object