Homec4science
Diffusion Genome Privacy - SHCS App (ms_access_migration) Browse

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

Last Change
Raw File

Reader_Job.java
View Options

//package raw_reader_mapreduce;
//
//import org.apache.hadoop.fs.Path;
//import org.apache.hadoop.io.IntWritable;
//import org.apache.hadoop.io.Text;
//import org.apache.hadoop.mapred.FileInputFormat;
//import org.apache.hadoop.mapred.FileOutputFormat;
//import org.apache.hadoop.mapred.JobClient;
//import org.apache.hadoop.mapred.JobConf;
//import org.apache.hadoop.mapred.Mapper;
//import org.apache.hadoop.mapred.Reducer;
//import org.apache.hadoop.mapred.TextInputFormat;
//import org.apache.hadoop.mapred.lib.db.DBConfiguration;
//import org.apache.hadoop.mapred.lib.db.DBOutputFormat;
//
//
//public class Reader_Job {
//
// public static void main(String[] args) throws Exception {
// JobConf conf = new JobConf(Reader_Job.class);
// conf.setJobName("encrypt");
//
// conf.setMapOutputKeyClass(IntWritable.class);
// conf.setMapOutputValueClass(Text.class);
//
//
// conf.setOutputKeyClass(EncWritable.class);
// conf.setOutputValueClass(IntWritable.class);
//
// conf.setMapperClass(Reader_Map.class);
//
// conf.setReducerClass(Reader_Reducer.class);
//
// conf.setInputFormat(TextInputFormat.class);
// conf.setOutputFormat(DBOutputFormat.class);
// DBConfiguration.configureDB(conf, "com.mysql.jdbc.Driver", "jdbc:mysql://localhost/pharmacogenomics_server?"
// + "user=root&password=admin");
// DBOutputFormat.setOutput(conf, "m_p", "ID_p","ID_m","enc_genotype_1","enc_genotype_2");
// FileInputFormat.setInputPaths(conf, new Path("In"));
// FileOutputFormat.setOutputPath(conf, new Path("Out"));
//
//
//
// JobClient.runJob(conf);
// }
//
//}
c4science · Help