Revision 53589
Added by Claudio Atzori over 5 years ago
modules/dnet-mapreduce-jobs/branches/master/src/main/java/eu/dnetlib/data/mapreduce/hbase/dataimport/GetInvalidXmlRecordsMapper.java | ||
---|---|---|
75 | 75 |
final String c = getInvalidXmlChar(e); |
76 | 76 |
if (StringUtils.isNotBlank(c)) { |
77 | 77 |
context.getCounter("invalid char", c).increment(1); |
78 |
} |
|
78 | 79 |
|
79 |
String doi = getDoi(value.toString()); |
|
80 |
if (StringUtils.isNotBlank(doi)) { |
|
81 |
valueOut.set(doi); |
|
82 |
context.write(key, valueOut); |
|
83 |
context.getCounter("output", "doi").increment(1); |
|
84 |
} |
|
85 |
|
|
80 |
String doi = getDoi(value.toString()); |
|
81 |
if (StringUtils.isNotBlank(doi)) { |
|
82 |
valueOut.set(doi); |
|
83 |
context.write(key, valueOut); |
|
84 |
context.getCounter("output", "doi").increment(1); |
|
86 | 85 |
} |
87 | 86 |
|
88 |
|
|
89 | 87 |
} |
90 | 88 |
} |
91 | 89 |
|
Also available in: Unified diff
export invalid xml records