Homec4science
Diffusion Genome Privacy - SHCS App (ms_access_migration) Browse

genopri-shcs/project/PPPServer/src/raw_reader_mapreduce/Reader_Map.java
a849cce6c01ams_access_migration

Last Change
Raw File

Reader_Map.java
View Options

//package raw_reader_mapreduce;
//
//import java.io.IOException;
//import java.math.BigInteger;
//import java.sql.SQLException;
//
//
//
//import org.apache.hadoop.io.IntWritable;
//import org.apache.hadoop.io.LongWritable;
//import org.apache.hadoop.io.Text;
//import org.apache.hadoop.io.Writable;
//import org.apache.hadoop.io.WritableComparable;
//import org.apache.hadoop.mapred.JobConf;
//import org.apache.hadoop.mapred.MapReduceBase;
//import org.apache.hadoop.mapred.Mapper;
//import org.apache.hadoop.mapred.OutputCollector;
//import org.apache.hadoop.mapred.Reporter;
//
//import paillier_crypto.CryptoException;
//import paillier_crypto.Scheme;
//import utils.DBconnector_server;
//import utils.KeyGenerator;
//
//public class Reader_Map extends MapReduceBase implements Mapper<LongWritable, Text, IntWritable, Text> {
//
// private BigInteger[] pbk;
// private int id_p;
// private String rs_code;
// private String[] alleles;
// private BigInteger genotype;
// private BigInteger[] cipherGenotype;
// private String[] tokens;
// private String line;
// private DBconnector_server conn_s;
// private Scheme cryptoScheme;
//
//
//
//
// @Override
// public void configure(JobConf job) {
//
// super.configure(job);
// conn_s = new DBconnector_server();
//// conn_s.openConnection();
//
//
// }
//
//
//
//
// @Override
// public void map(LongWritable key, Text value, OutputCollector<IntWritable,
// Text> output, Reporter reporter) throws IOException {
// try {
// line = value.toString();
// tokens = line.split("\t");
// if(tokens[0].matches("^(rs|chr|seq|Seq|SEQ).*$")){
// int pat = Integer.parseInt(tokens[1]);
//
//
// if(pat != id_p){
// id_p = pat;
// pbk = conn_s.getPublicKey(id_p);
// cryptoScheme = new Scheme(pbk[0], pbk[1], pbk[2]);
// }
//
// //rs_code
// rs_code = tokens[0];
// if(rs_code.contains("seq") || rs_code.contains("Seq") || rs_code.contains("SEQ")){
// String[] string = rs_code.split("-");
// rs_code = string[1];
// }
//
// alleles = conn_s.getAlleles(rs_code);
// if(tokens[2].equals(alleles[0]) && tokens[3].equals(alleles[0])){
// genotype = BigInteger.valueOf(2);
// }else if(tokens[2].equals(alleles[1]) && tokens[3].equals(alleles[1])){
// genotype = BigInteger.valueOf(0);
// }else{
// genotype = BigInteger.valueOf(1);
// }
//
//
// if(alleles[2] == null){
// System.out.println(rs_code);
// }
//
// cipherGenotype = cryptoScheme.encrypt(genotype);
//
// output.collect(new IntWritable(id_p), new Text(alleles[2] + ";" + cipherGenotype[0].toString() + ";" + cipherGenotype[1].toString()));
//
// cipherGenotype = null;
// System.gc();
//
//
//
// }
//
// } catch (NumberFormatException e) {
//
// e.printStackTrace();
//
// } catch (SQLException e) {
//
// e.printStackTrace();
// } catch (CryptoException e) {
//
// e.printStackTrace();
// }
//
//
// }
//
//}
c4science · Help