D-Net

import java.io.IOException;

import org.apache.hadoop.conf.Configuration;

import org.apache.hadoop.io.NullWritable;

import org.apache.hadoop.io.Text;

import org.json.JSONObject;

import eu.dnetlib.data.mapreduce.hbase.lodImport.utils.DB;

import java.util.Arrays;

public class LodImportReducer extends Reducer<Text, Text, NullWritable, NullWritable> {

    private Logger log = Logger.getLogger(LodImportReducer.class);

    private Configuration hadoopConf;

    @Override

        this.fileName = hadoopConf.get("lod.inputFile");

        this.hadoopConf = context.getConfiguration();

        try {

            ds = DB.getDatasource(hadoopConf.get("lod.conLine"), hadoopConf.get("lod.username"), hadoopConf.get("lod.password"), hadoopConf.get("lod.minCpart"), hadoopConf.get("lod.maxCpart"), hadoopConf.get("lod.part"));

        } catch (Exception e) {

        }

    }

    @Override

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

        JSONObject entitiesMappings = new JSONObject(hadoopConf.get("lod.jsonEntities"));

//		Connection conn = ds.getConnection();

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

        while (it.hasNext()) {

            String split= it.next().toString();

            System.out.println(" Values : ");

            if (fileName.startsWith("entities")) RDFizer.RDFizeEntityRow(row, ds, entitiesMappings,hadoopConf);

        }

    }

    @Override

}