Revision 50598
Added by Sandro La Bruzzo about 6 years ago
| FetchMDStoreRecordsJobNode.java | ||
|---|---|---|
| 39 | 39 |
setMdFormat(token.getEnv().getAttribute("mdFormat"));
|
| 40 | 40 |
} |
| 41 | 41 |
|
| 42 |
final Long dateFromFilter = token.getFullEnv().getAttribute("DateFromFilter", Long.class);
|
|
| 43 |
|
|
| 44 |
if (dateFromFilter!= null) {
|
|
| 45 |
log.info("From Filter activated, from:"+dateFromFilter);
|
|
| 46 |
} |
|
| 47 |
|
|
| 48 |
|
|
| 49 |
|
|
| 42 | 50 |
final MDStoreService mdStoreService = serviceLocator.getService(MDStoreService.class, getMdId()); |
| 43 | 51 |
int size = mdStoreService.size(getMdId()); |
| 44 | 52 |
|
| 45 | 53 |
token.getEnv().setAttribute(WorkflowsConstants.MAIN_LOG_PREFIX + "sourceSize", size); |
| 46 | 54 |
log.info(String.format("getting MDRecords from: %s, sourceSize: %s", getMdId(), size));
|
| 47 | 55 |
|
| 48 |
final W3CEndpointReference epr = mdStoreService.deliverMDRecords(getMdId(), "", "", ""); |
|
| 56 |
final W3CEndpointReference epr = mdStoreService.deliverMDRecords(getMdId(), dateFromFilter!=null?""+dateFromFilter:"", "", "");
|
|
| 49 | 57 |
if (epr == null) { throw new MSROException("unable to read MDRecords from: " + getMdId()); }
|
| 50 | 58 |
token.getEnv().setAttribute(getEprParam(), epr.toString()); |
| 51 | 59 |
return Arc.DEFAULT_ARC; |
Also available in: Unified diff
-Incremental transformation: Implemented incremental transformation and changed the nodes Fetch and Store MDRecords to read in the env the property of incremental read and store if there is, otherwise they work as usual