Revision 56873
Added by Alessia Bardi over 4 years ago
| IncrementalTransformationJobNode.java | ||
|---|---|---|
| 21 | 21 |
private static final DateUtils dateUtils = new DateUtils(); |
| 22 | 22 |
|
| 23 | 23 |
@Override |
| 24 |
protected boolean forceRefresh(final NodeToken nodeToken, final Long lastSuccessEndDate, final String currentWfProfileId) throws Exception {
|
|
| 25 |
if (lastSuccessEndDate < 0) {
|
|
| 26 |
nodeToken.getFullEnv().setAttribute("OperationTypeInfo", "Last success date < 0, transformation forced to REFRESH");
|
|
| 24 |
protected boolean forceRefresh(final NodeToken nodeToken, final Long lastSuccessStartDate, final String currentWfProfileId) throws Exception {
|
|
| 25 |
if (lastSuccessStartDate < 0) {
|
|
| 26 |
nodeToken.getFullEnv().setAttribute("OperationTypeInfo", "Last success start date < 0, transformation forced to REFRESH");
|
|
| 27 | 27 |
nodeToken.getFullEnv().setAttribute("operationType", "REFRESH");
|
| 28 | 28 |
return true; |
| 29 | 29 |
} |
| ... | ... | |
| 31 | 31 |
final long lastUpdateDate = getLastTransformationRuleUpdate(trRuleId); |
| 32 | 32 |
log.info(String.format("Last update date of the transformation rule with id %s is %s", trRuleId, DateUtils.calculate_ISO8601(lastUpdateDate)));
|
| 33 | 33 |
|
| 34 |
if (lastUpdateDate > lastSuccessEndDate) {
|
|
| 34 |
if (lastUpdateDate > lastSuccessStartDate) {
|
|
| 35 | 35 |
nodeToken.getFullEnv().setAttribute("OperationTypeInfo", "Transformation Rule has been updated, transformation forced to REFRESH");
|
| 36 | 36 |
nodeToken.getFullEnv().setAttribute("operationType", "REFRESH");
|
| 37 | 37 |
return true; |
Also available in: Unified diff
Fixes #3191#note-20: incremental transformation