Revision 27945
Added by Claudio Atzori about 10 years ago
modules/dnet-openaireplus-workflows/branches/2.0.0/src/main/java/eu/dnetlib/msro/openaireplus/workflows/nodes/index/SwitchIndexJobNode.java | ||
---|---|---|
1 |
package eu.dnetlib.msro.openaireplus.workflows.nodes.index; |
|
2 |
|
|
3 |
import com.googlecode.sarasvati.NodeToken; |
|
4 |
|
|
5 |
import eu.dnetlib.enabling.tools.blackboard.BlackboardJob; |
|
6 |
import eu.dnetlib.msro.workflows.nodes.BlackboardJobNode; |
|
7 |
|
|
8 |
public class SwitchIndexJobNode extends BlackboardJobNode { |
|
9 |
|
|
10 |
private final String xquery = "/RESOURCE_PROFILE[.//RESOURCE_TYPE/@value='SearchServiceResourceType']/HEADER/RESOURCE_IDENTIFIER/@value/string()"; |
|
11 |
|
|
12 |
@Override |
|
13 |
protected String getXqueryForServiceId(NodeToken token) { |
|
14 |
return xquery; |
|
15 |
} |
|
16 |
|
|
17 |
@Override |
|
18 |
protected void prepareJob(BlackboardJob job, NodeToken token) throws Exception { |
|
19 |
|
|
20 |
job.setAction("UpdateIndex"); |
|
21 |
job.getParameters().put("IndexId", token.getEnv().getAttribute("id")); |
|
22 |
|
|
23 |
} |
|
24 |
|
|
25 |
} |
modules/dnet-openaireplus-workflows/branches/2.0.0/src/main/resources/eu/dnetlib/test/profiles/openaireplus/workflows/provision/index.xml | ||
---|---|---|
69 | 69 |
</PARAMETERS> |
70 | 70 |
<ARCS> |
71 | 71 |
<ARC to="group" /> |
72 |
<ARC to="updateStats" /> |
|
72 | 73 |
</ARCS> |
73 | 74 |
</NODE> |
74 | 75 |
<NODE name="group" type="SubmitHadoopJob" isJoin="true"> |
... | ... | |
92 | 93 |
</PARAMETERS> |
93 | 94 |
<ARCS> |
94 | 95 |
<ARC to="updateIndex" /> |
95 |
<!-- <ARC to="updateStats" /> --> |
|
96 | 96 |
</ARCS> |
97 | 97 |
</NODE> |
98 | 98 |
<NODE name="updateIndex" type="SubmitHadoopJob"> |
... | ... | |
118 | 118 |
</PARAM> |
119 | 119 |
</PARAMETERS> |
120 | 120 |
<ARCS> |
121 |
<ARC to="sync" /> |
|
122 |
</ARCS> |
|
123 |
</NODE> |
|
124 |
<NODE name="updateStats" type="SubmitHadoopMapReduce"> |
|
125 |
<DESCRIPTION>update stats</DESCRIPTION> |
|
126 |
<PARAMETERS /> |
|
127 |
<ARCS> |
|
128 |
<ARC to="sync" /> |
|
129 |
</ARCS> |
|
130 |
</NODE> |
|
131 |
<NODE name="sync" isJoin="true"> |
|
132 |
<DESCRIPTION /> |
|
133 |
<PARAMETERS /> |
|
134 |
<ARCS> |
|
121 | 135 |
<ARC to="finalize" /> |
122 | 136 |
</ARCS> |
123 |
</NODE> |
|
124 |
<!-- <NODE name="updateStats" type="SubmitHadoopMapReduce"> --> |
|
125 |
<!-- <DESCRIPTION>M/R update stats</DESCRIPTION> --> |
|
126 |
<!-- <PARAMETERS /> --> |
|
127 |
<!-- <ARCS> --> |
|
128 |
<!-- <ARC to="sync" /> --> |
|
129 |
<!-- </ARCS> --> |
|
130 |
<!-- </NODE> --> |
|
131 |
<!-- <NODE name="sync" isJoin="true"> --> |
|
132 |
<!-- <DESCRIPTION /> --> |
|
133 |
<!-- <PARAMETERS /> --> |
|
134 |
<!-- <ARCS> --> |
|
135 |
<!-- <ARC to="finalize" /> --> |
|
136 |
<!-- </ARCS> --> |
|
137 |
<!-- </NODE> --> |
|
137 |
</NODE> |
|
138 | 138 |
<NODE name="finalize" type="FinalizeIndexFeeding"> |
139 | 139 |
<DESCRIPTION>commit changes</DESCRIPTION> |
140 | 140 |
<PARAMETERS /> |
... | ... | |
146 | 146 |
<DESCRIPTION>update DS</DESCRIPTION> |
147 | 147 |
<PARAMETERS /> |
148 | 148 |
<ARCS> |
149 |
<ARC to="switch" /> |
|
150 |
</ARCS> |
|
151 |
</NODE> |
|
152 |
<NODE name="switch" type="SwitchIndex"> |
|
153 |
<DESCRIPTION>switch index</DESCRIPTION> |
|
154 |
<PARAMETERS /> |
|
155 |
<ARCS> |
|
149 | 156 |
<ARC to="success" /> |
150 | 157 |
</ARCS> |
151 |
</NODE> |
|
158 |
</NODE>
|
|
152 | 159 |
</CONFIGURATION> |
153 | 160 |
<STATUS /> |
154 | 161 |
</BODY> |
modules/dnet-openaireplus-workflows/branches/2.0.0/src/main/resources/eu/dnetlib/msro/openaireplus/workflows/applicationContext-msro-openaire-nodes.xml | ||
---|---|---|
177 | 177 |
p:xqueryDataciteObjectStore="${dnet.openaire.iis.objecstores.dataset.xquery}" |
178 | 178 |
p:xqueryWosObjectStore="${dnet.openaire.iis.objecstores.wos.xquery}"/> |
179 | 179 |
|
180 |
<bean id="wfNodeSwitchIndex" class="eu.dnetlib.msro.openaireplus.workflows.nodes.index.SwitchIndexJobNode" |
|
181 |
scope="prototype" |
|
182 |
p:xquery="${}"/> |
|
183 |
|
|
180 | 184 |
</beans> |
Also available in: Unified diff
extension of the index feeding job.