Revision 29348
Added by Eri Katsari over 10 years ago
| modules/dnet-openaire-stats/trunk/src/main/java/eu/dnetlib/data/mapreduce/hbase/statsExport/utils/Serializer.java | ||
|---|---|---|
| 212 | 212 |
String buff = new String(); |
| 213 | 213 |
if (topic.getValue() != null && !topic.getValue().isEmpty()) {
|
| 214 | 214 |
buff += topic.getValue(); |
| 215 |
buffs.add(getStringField(buff)); |
|
| 216 |
} |
|
| 215 |
|
|
| 216 |
}buffs.add(getStringField(buff));
|
|
| 217 | 217 |
} |
| 218 | 218 |
rels.put("resultTopic", buffs);
|
| 219 | 219 |
|
| ... | ... | |
| 628 | 628 |
if (value != null) {
|
| 629 | 629 |
value = value.replaceFirst(".*\\|", "");
|
| 630 | 630 |
value = value.replaceAll("\n", "");
|
| 631 |
value = value.replaceAll(ENCLOSED, ""); |
|
| 631 | 632 |
value = value.trim(); |
| 632 | 633 |
|
| 633 | 634 |
} |
| ... | ... | |
| 635 | 636 |
if (!value.contains(ENCLOSED)) {
|
| 636 | 637 |
return ENCLOSED + value + ENCLOSED; |
| 637 | 638 |
} else {
|
| 639 |
|
|
| 640 |
|
|
| 638 | 641 |
return value; |
| 639 | 642 |
} |
| 640 | 643 |
} |
Also available in: Unified diff