Revision 48139
Added by Alessia Bardi almost 7 years ago
| CheckHDFSCountJobNode.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.rmi.MSROException; |
| 10 | 6 |
import eu.dnetlib.msro.workflows.nodes.SimpleJobNode; |
| 11 | 7 |
import eu.dnetlib.msro.workflows.util.WorkflowsConstants; |
| 8 |
import org.apache.commons.logging.Log; |
|
| 9 |
import org.apache.commons.logging.LogFactory; |
|
| 12 | 10 |
|
| 13 | 11 |
public class CheckHDFSCountJobNode extends SimpleJobNode {
|
| 14 | 12 |
|
| 15 | 13 |
private static final Log log = LogFactory.getLog(CheckHDFSCountJobNode.class); // NOPMD by marko on 11/24/08 5:02 PM |
| 16 | 14 |
|
| 17 |
/** Name of the env param where to find the number to check. **/ |
|
| 15 |
/** |
|
| 16 |
* Name of the env param where to find the number to check. |
|
| 17 |
**/ |
|
| 18 | 18 |
private String numberToVerifyParamName; |
| 19 |
/** Name of the enc param where to find the number of records stored to hdfs. **/ |
|
| 19 |
/** |
|
| 20 |
* Name of the enc param where to find the number of records stored to hdfs. |
|
| 21 |
**/ |
|
| 20 | 22 |
private String hdfsCounterParamName = "mainlog:storeHdfsRecords:count"; |
| 21 | 23 |
|
| 22 | 24 |
/** |
| 23 | 25 |
* {@inheritDoc}
|
| 24 |
*
|
|
| 26 |
* |
|
| 25 | 27 |
* @throws MSROException |
| 26 |
* |
|
| 27 | 28 |
* @see com.googlecode.sarasvati.mem.MemNode#execute(com.googlecode.sarasvati.Engine, com.googlecode.sarasvati.NodeToken) |
| 28 | 29 |
*/ |
| 29 | 30 |
@Override |
Also available in: Unified diff
integrated (hopefully) all required changes from dnet40