Revision 40094
Added by Michele Artini over 8 years ago
UnpackJobNode.java | ||
---|---|---|
4 | 4 |
import java.util.Iterator; |
5 | 5 |
import java.util.Queue; |
6 | 6 |
import java.util.concurrent.PriorityBlockingQueue; |
7 |
|
|
8 | 7 |
import javax.xml.ws.wsaddressing.W3CEndpointReference; |
9 | 8 |
|
9 |
import eu.dnetlib.enabling.resultset.IterableResultSetFactory; |
|
10 |
import eu.dnetlib.enabling.resultset.client.ResultSetClientFactory; |
|
11 |
import eu.dnetlib.msro.workflows.graph.Arc; |
|
12 |
import eu.dnetlib.msro.workflows.graph.Env; |
|
13 |
import eu.dnetlib.msro.workflows.nodes.SimpleJobNode; |
|
10 | 14 |
import org.apache.commons.logging.Log; |
11 | 15 |
import org.apache.commons.logging.LogFactory; |
12 | 16 |
import org.dom4j.Document; |
... | ... | |
14 | 18 |
import org.dom4j.io.SAXReader; |
15 | 19 |
import org.springframework.beans.factory.annotation.Required; |
16 | 20 |
|
17 |
import com.googlecode.sarasvati.Arc; |
|
18 |
import com.googlecode.sarasvati.NodeToken; |
|
19 |
|
|
20 |
import eu.dnetlib.enabling.resultset.IterableResultSetFactory; |
|
21 |
import eu.dnetlib.enabling.resultset.client.ResultSetClientFactory; |
|
22 |
import eu.dnetlib.msro.workflows.nodes.SimpleJobNode; |
|
23 |
|
|
24 | 21 |
public class UnpackJobNode extends SimpleJobNode { |
25 | 22 |
|
26 | 23 |
/** |
... | ... | |
36 | 33 |
private ResultSetClientFactory resultSetClientFactory; |
37 | 34 |
|
38 | 35 |
@Override |
39 |
protected String execute(final NodeToken token) throws Exception {
|
|
40 |
final Iterator<String> client = resultSetClientFactory.getClient(token.getEnv().getAttribute(inputEprParam)).iterator();
|
|
36 |
protected String execute(final Env env) throws Exception {
|
|
37 |
final Iterator<String> client = resultSetClientFactory.getClient(env.getAttribute(inputEprParam, String.class)).iterator();
|
|
41 | 38 |
final Queue<String> queue = new PriorityBlockingQueue<String>(); |
42 | 39 |
|
43 | 40 |
while (queue.isEmpty() && client.hasNext()) { |
... | ... | |
69 | 66 |
} |
70 | 67 |
|
71 | 68 |
@Override |
72 |
public void remove() {} |
|
69 |
public void remove() { |
|
70 |
} |
|
73 | 71 |
}; |
74 | 72 |
} |
75 | 73 |
}); |
76 | 74 |
|
77 |
token.getEnv().setAttribute(outputEprParam, epr.toString());
|
|
75 |
env.setAttribute(outputEprParam, epr.toString());
|
|
78 | 76 |
|
79 | 77 |
return Arc.DEFAULT_ARC; |
80 | 78 |
} |
Also available in: Unified diff
partial reimplementation of the wf engine