-
Notifications
You must be signed in to change notification settings - Fork 0
Expand file tree
/
Copy pathProbability_Compute_Driver.java
More file actions
26 lines (24 loc) · 1.01 KB
/
Probability_Compute_Driver.java
File metadata and controls
26 lines (24 loc) · 1.01 KB
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
package Naive_Bayes;
/*@Author - Arkadipta De*/
import java.io.IOException;
import java.util.HashMap;
import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.fs.Path;
import org.apache.hadoop.io.Text;
import org.apache.hadoop.mapreduce.Job;
import org.apache.hadoop.mapreduce.lib.input.FileInputFormat;
import org.apache.hadoop.mapreduce.lib.output.FileOutputFormat;
public class Probability_Compute_Driver
{public static void main(String args[]) throws IOException, ClassNotFoundException, InterruptedException
{Configuration conf = new Configuration();
Job job = Job.getInstance(conf, "Probability_Computaion");
job.setJarByClass(Probability_Compute_Driver.class);
job.setMapperClass(Probability_Compute_Mapper.class);
job.setNumReduceTasks(0);
job.setOutputKeyClass(Text.class);
job.setOutputValueClass(HashMap.class);
FileInputFormat.addInputPath(job,new Path("bankdata"));
FileOutputFormat.setOutputPath(job,new Path("bankdata_Prediction"));
job.waitForCompletion(true);
}
}