Revision 43485
Added by Eri Katsari almost 8 years ago
| SourceMapper.java | ||
|---|---|---|
| 31 | 31 |
|
| 32 | 32 |
private LodConfiguration lodConfiguration; |
| 33 | 33 |
|
| 34 |
public static enum ENTITIES_COUNTER {
|
|
| 34 |
public static enum SOURCE_COUNTERS {
|
|
| 35 | 35 |
|
| 36 | 36 |
SOURCE_ENTITIES, |
| 37 | 37 |
} |
| ... | ... | |
| 95 | 95 |
|
| 96 | 96 |
Text key = new Text("OA" + "," + type + "," + subject);
|
| 97 | 97 |
context.write(key, new Text(value.toString())); |
| 98 |
context.getCounter(ENTITIES_COUNTER.SOURCE_ENTITIES).increment(1);
|
|
| 98 |
context.getCounter(SOURCE_COUNTERS.SOURCE_ENTITIES).increment(1);
|
|
| 99 | 99 |
} |
| 100 | 100 |
} catch (Exception e) {
|
| 101 | 101 |
log.error("Error writing entity to M/R output", e);
|
Also available in: Unified diff
fixes