public class JobData extends Object implements Serializable
Modifier and Type | Class and Description |
---|---|
static class |
JobData.Result
Represents the result of the last execution of the job.
|
static class |
JobData.State
An enumeration of job states.
|
Modifier and Type | Field and Description |
---|---|
protected static long |
serialVersionUID
For interoperability with possible future changes.
|
Constructor and Description |
---|
JobData() |
JobData(int jobID,
String name,
String type) |
Modifier and Type | Method and Description |
---|---|
void |
addExporterWithUnknownExportedTuples(String exporterName) |
Serializable |
getCombinations()
Gets the values of the parameters of a parameterized query (in order to not query the sources when retrying a job).
|
Map<String,Long> |
getExportationErrors() |
Map<String,Long> |
getExportationGlobalResult() |
Map<String,Long> |
getExportationResult() |
Map<String,Long> |
getExportationWarnings() |
Set<String> |
getExportersWithUnknownExportedTuples()
Returns the list of exporter names which may have exported more than the tuples indicated in
getExportationResult() . |
long |
getExtractionErrors() |
long |
getExtractionGlobalResult() |
long |
getExtractionResult() |
long |
getExtractionWarnings() |
long |
getFirstExecution()
Returns the first time in milliseconds at which the job was fire.
|
int |
getJobID() |
JobData.Result |
getLastResult() |
String |
getName() |
Date |
getNextExecution()
Returns the next time at which the job will fire.
|
long |
getParametersExecuted() |
Date |
getPreviousExecution()
Returns the previous time at which the job will fire.
|
int |
getProjectId() |
String |
getProjectName() |
Serializable |
getQueryErrors()
Gets the queries which returned an error (for retrying them if needed).
|
Serializable |
getQuerySuccess()
Gets the queries which did not returned an error (for not retrying them).
|
int |
getRetryCount() |
JobData.State |
getState() |
String |
getType() |
void |
incExportationErrors(String exporterID,
long num) |
void |
incExportationGlobalResult(String exporterID,
long num) |
void |
incExportationResult(String exporterID,
long num) |
void |
incExportationWarnings(String exporterID,
long num) |
void |
incExtractionErrors(long num) |
void |
incExtractionGlobalResult(long num) |
void |
incExtractionResult(long num) |
void |
incExtractionWarnings(long num) |
void |
incParametersExecuted(long num) |
boolean |
isInterrupted() |
boolean |
isStartedWithState() |
void |
reset() |
boolean |
retryJob() |
void |
setCombinations(Serializable combinations) |
void |
setExportationErrors(Map<String,Long> exportationErrors) |
void |
setExportationGlobalResult(Map<String,Long> exportationGlobalResult) |
void |
setExportationResult(Map<String,Long> exportationResult) |
void |
setExportationWarnings(Map<String,Long> exportationWarnings) |
void |
setFirstExecution(long firstExecution)
Sets the first time in milliseconds at which the job was fire.
|
void |
setInterrupted(boolean interrupted) |
void |
setLastResult(JobData.Result lastResult) |
void |
setName(String name) |
void |
setNextExecution(Date nextExecution)
Sets the next time at which the job will fire.
|
void |
setPreviousExecution(Date previousExecution)
Sets the previous time at which the job will fire.
|
void |
setProjectId(int projectId) |
void |
setProjectName(String name) |
void |
setQueryErrors(Serializable queryErrors) |
void |
setQuerySuccess(Serializable querySuccess) |
void |
setRetryCount(int retryCount) |
void |
setRetryJob(boolean retryJob) |
void |
setStartedWithState(boolean startedWithState) |
void |
setState(JobData.State state) |
void |
setType(String type) |
String |
toString() |
protected static final long serialVersionUID
public int getJobID()
public String getProjectName()
public void setProjectName(String name)
name
- the project name to setpublic int getProjectId()
public void setProjectId(int projectId)
projectId
- the project projectId to setpublic String getName()
public void setName(String name)
name
- the name to setpublic String getType()
public void setType(String type)
type
- the type to setpublic JobData.State getState()
public void setState(JobData.State state)
state
- the state to setpublic JobData.Result getLastResult()
public void setLastResult(JobData.Result lastResult)
lastResult
- the lastResult to setpublic long getFirstExecution()
public void setFirstExecution(long firstExecution)
firstExecution
- the firstExecution to setpublic Date getPreviousExecution()
public void setPreviousExecution(Date previousExecution)
previousExecution
- the previousExecution to setpublic Date getNextExecution()
public void setNextExecution(Date nextExecution)
nextExecution
- the nextExecution to setpublic long getExtractionResult()
public void incExtractionResult(long num)
public long getExtractionGlobalResult()
public void incExtractionGlobalResult(long num)
public long getExtractionErrors()
public void incExtractionErrors(long num)
public long getExtractionWarnings()
public void incExtractionWarnings(long num)
public void incExportationResult(String exporterID, long num)
public Map<String,Long> getExportationGlobalResult()
public void setExportationGlobalResult(Map<String,Long> exportationGlobalResult)
public void incExportationGlobalResult(String exporterID, long num)
public void incExportationErrors(String exporterID, long num)
public Map<String,Long> getExportationWarnings()
public void incExportationWarnings(String exporterID, long num)
public long getParametersExecuted()
public void incParametersExecuted(long num)
public Set<String> getExportersWithUnknownExportedTuples()
getExportationResult()
. Related to batch inserts in JDBCExporters.public void addExporterWithUnknownExportedTuples(String exporterName)
public Serializable getQueryErrors()
Map<Integer, List<Integer>>
; otherwise, a List<Integer>
.public void setQueryErrors(Serializable queryErrors)
public Serializable getQuerySuccess()
Map<Integer, List<Integer>>
; otherwise, a List<Integer>
.public void setQuerySuccess(Serializable querySuccess)
public int getRetryCount()
public void setRetryCount(int retryCount)
public boolean retryJob()
public void setRetryJob(boolean retryJob)
public boolean isInterrupted()
public void setInterrupted(boolean interrupted)
public Serializable getCombinations()
Map<Integer, List<Serializable>>
; otherwise, a List<Serializable>
.public void setCombinations(Serializable combinations)
public void reset()
public boolean isStartedWithState()
public void setStartedWithState(boolean startedWithState)
Copyright © 2024 Denodo Technologies. All rights reserved.