Revision 48139
Added by Alessia Bardi over 6 years ago
SetHdfsFileJobNode.java | ||
---|---|---|
1 | 1 |
package eu.dnetlib.msro.openaireplus.workflows.nodes; |
2 | 2 |
|
3 |
import org.apache.commons.logging.Log; |
|
4 |
import org.apache.commons.logging.LogFactory; |
|
5 |
|
|
6 | 3 |
import com.googlecode.sarasvati.Arc; |
7 | 4 |
import com.googlecode.sarasvati.NodeToken; |
8 |
|
|
9 | 5 |
import eu.dnetlib.msro.workflows.nodes.SimpleJobNode; |
6 |
import org.apache.commons.logging.Log; |
|
7 |
import org.apache.commons.logging.LogFactory; |
|
10 | 8 |
|
11 | 9 |
/** |
12 | 10 |
* The Class SetHdfsFileJobNode. |
... | ... | |
18 | 16 |
*/ |
19 | 17 |
private static final Log log = LogFactory.getLog(SetHdfsFileJobNode.class); // NOPMD by marko on 11/24/08 5:02 PM |
20 | 18 |
|
21 |
/** The input records path. */ |
|
19 |
/** |
|
20 |
* The input records path. |
|
21 |
*/ |
|
22 | 22 |
private String hdfsPath; |
23 | 23 |
|
24 |
/** The input records path param. */ |
|
24 |
/** |
|
25 |
* The input records path param. |
|
26 |
*/ |
|
25 | 27 |
private String hdfsPathParam; |
26 | 28 |
|
27 | 29 |
/** |
28 | 30 |
* {@inheritDoc} |
29 |
*
|
|
31 |
* |
|
30 | 32 |
* @see com.googlecode.sarasvati.mem.MemNode#execute(com.googlecode.sarasvati.Engine, com.googlecode.sarasvati.NodeToken) |
31 | 33 |
*/ |
32 | 34 |
@Override |
Also available in: Unified diff
integrated (hopefully) all required changes from dnet40