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