Revision 29180
Added by Eri Katsari over 10 years ago
| modules/dnet-openaire-stats/trunk/src/main/java/eu/dnetlib/data/mapreduce/hbase/statsExport/StatsReducer.java | ||
|---|---|---|
| 38 | 38 |
counter++; |
| 39 | 39 |
|
| 40 | 40 |
value = value.trim(); |
| 41 |
// MultipleOutputWriter.write(type, " " + new Text(id), new Text(context.getConfiguration().get("stats.delim") + value), type.toString());
|
|
| 42 |
MultipleOutputWriter.write(type,new Text(id), new Text(value), type.toString()); |
|
| 41 |
MultipleOutputWriter.write(type,new Text(id), new Text(value), type.toString()); |
|
| 43 | 42 |
|
| 44 | 43 |
|
| 45 | 44 |
} |
Also available in: Unified diff