Revision 48805
Added by Eri Katsari almost 7 years ago
| BlockNoCacheReducer.java | ||
|---|---|---|
| 42 | 42 |
protected void reduce(final Text key, final Iterable<Text> values, final Context context) throws IOException, InterruptedException {
|
| 43 | 43 |
Iterator<Text> it = values.iterator(); |
| 44 | 44 |
StringBuilder field = new StringBuilder(); |
| 45 |
Map<String, String> records = new HashMap(); |
|
| 45 |
Map<String, String> records = new HashMap<>();
|
|
| 46 | 46 |
|
| 47 | 47 |
try {
|
| 48 | 48 |
boolean hasSource = false; |
Also available in: Unified diff
Final update- fixed distance algs, added props un wf