D-Net

public class DatasetReducer extends Reducer<Text, Text, Text, Text> {

    public static enum ENTITIES_COUNTER {

        TOTAL_ENTITIES,

    }

    protected void reduce(final Text key, final Iterable<Text> values, final Context context) throws IOException, InterruptedException {

        Iterator<Text> it = values.iterator();

        StringBuffer value = new StringBuffer();

        String[] tmp = key.toString().split(",");

        String dataset = tmp[0].replaceAll("[^a-zA-Z0-9]", "");

        String entityType = tmp[1].replaceAll("[^a-zA-Z0-9]", "");