public class VDPDataLoadJobReport extends AbstractExtractionJobReport
Modifier and Type | Field and Description |
---|---|
protected static long |
serialVersionUID
For interoperability with possible future changes.
|
extractedDocs, extractorErrorsCount, extractorWarningsCount, maxErrorsToSave
readWriteLock
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) |
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() |
addExtractorError, addExtractorWarning, getExtractedDocs, getExtractorErrors, getExtractorErrorsCount, getExtractorWarnings, getExtractorWarningsCount, hasWarnings, incExtractedDocs, setExtractedDocs, setExtractorErrors, setExtractorWarnings
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
protected static final long serialVersionUID
public VDPDataLoadJobReport()
public VDPDataLoadJobReport(int jobID, String jobName, String jobType, Date startTime, String query)
public String getQuery()
public void setQuery(String query)
public String getLoadProcessName()
public void setLoadProcessName(String loadProcessName)
public Map<Integer,VDPDataLoadJobReport> getReports()
public void addReport(int execution, VDPDataLoadJobReport report)
public void addReport(int parent, int execution, VDPDataLoadJobReport reportToAdd)
public void removeReport(int execution)
public void removeReport(int parent, int execution)
public void setEndTime(int parent, int execution, Date date)
public void setEndTime(int execution, Date date)
public void incExtractedDocs(int parent, int execution, long numDocs)
public void incExtractedDocs(int execution, long numDocs)
public void addExtractorError(int taskId, int execution, String extractorError)
public void addExtractorError(int execution, String extractorError)
public void addExtractorWarning(int taskId, int execution, String extractorWarning)
public void addExtractorWarning(int execution, String extractorWarning)
public long getInsertErrorsCount()
public long getInsertedDocs()
public void incInsertedDocs(long numDocs)
public void incInsertedDocs(int parent, int execution, long numDocs)
public void incInsertedDocs(int execution, long numDocs)
public Collection<Object> getInsertErrors()
public void addInsertError(String insertError)
public void addInsertError(int parent, int execution, String insertError)
public void addInsertError(int execution, String insertError)
public void setPreviousExecutionSuccess(Map<Integer,List<Integer>> previousExecutionSuccess)
previousExecutionSuccess
- the previousExecutionSuccess to setpublic void setPreviousExecutionErrors(Map<Integer,List<Integer>> previousExecutionErrors)
previousExecutionErrors
- the previousExecutionErrors to setpublic List<Integer> getSuccessExecutions(int parent)
parent
- the load process identifierpublic Map<Integer,List<Integer>> getSuccessExecutions()
public boolean hasErrors()
hasErrors
in interface JobReport
hasErrors
in class AbstractExtractionJobReport
public boolean containsRetryableErrors()
containsRetryableErrors
in class AbstractExtractionJobReport
public void reset()
reset
in interface JobReport
reset
in class AbstractExtractionJobReport
public String toString()
toString
in class AbstractExtractionJobReport
Copyright © 2025 Denodo Technologies. All rights reserved.