Revision 56504
Added by Antonis Lempesis almost 5 years ago
| StatsReducer.java | ||
|---|---|---|
| 37 | 37 |
String value = new String(it.next().copyBytes(),Charset.forName("UTF-8"));
|
| 38 | 38 |
value = value.trim(); |
| 39 | 39 |
MultipleOutputWriter.write(type, new Text(id.getBytes(Charset.forName("UTF-8"))), new Text(value.getBytes(Charset.forName("UTF-8"))), type.toString());
|
| 40 |
|
|
| 41 | 40 |
} |
| 42 |
|
|
| 43 | 41 |
} |
| 44 | 42 |
|
| 45 | 43 |
@Override |
Also available in: Unified diff
- Made Serializers methods non static to improve readability and maintenability.
- Code cleanup