LeagueOfLegendsDataAnalysis/subtask4.java at master · krishmoodbidri/LeagueOfLegendsDataAnalysis · GitHub

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
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
package test2;

import java.io.IOException;

import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.fs.Path;
import org.apache.hadoop.io.IntWritable;
import org.apache.hadoop.io.Text;
import org.apache.hadoop.mapreduce.Job;
import org.apache.hadoop.mapreduce.Mapper;
import org.apache.hadoop.mapreduce.Reducer;
import org.apache.hadoop.mapreduce.lib.input.FileInputFormat;
import org.apache.hadoop.mapreduce.lib.output.FileOutputFormat;
import org.json.JSONArray;
import org.json.JSONObject;

public class subtask4
{
    public static void main( String[] args ) throws Exception
    {
    	Configuration conf = new Configuration();
    	Job job = Job.getInstance(conf, "Win rate wrt mmr");
	    job.setJarByClass(subtask4.class);
	    job.setMapperClass(st4Mapper.class);
	    job.setCombinerClass(st4Reducer.class);
	    job.setReducerClass(st4Reducer.class);
	    job.setOutputKeyClass(Text.class);
	    job.setOutputValueClass(IntWritable.class);
	    job.setNumReduceTasks(20);
	    FileInputFormat.addInputPath(job, new Path(args[0]));
	    FileOutputFormat.setOutputPath(job, new Path(args[1]));
	    System.exit(job.waitForCompletion(true) ? 0 : 1);
    }

    static class st4Mapper extends Mapper<Object, Text, Text, IntWritable> {

    	private Text champion = new Text();
    	private static final IntWritable one = new IntWritable(1);
		private static final IntWritable zero = new IntWritable(0);
		private Text write = new Text();

		public void map(Object key, Text value, Context context) throws IOException, InterruptedException {
			String jsonString = value.toString();
			JSONObject obj = new JSONObject(jsonString);
			int mmr = obj.getInt("mmr");
			int winner = obj.getInt("winner");


			JSONArray players = obj.getJSONArray("players");
			for (int i = 0; i < players.length(); i++) {
				JSONObject o = players.getJSONObject(i);


				int teamID = o.getInt("teamID");
				int championID = o.getInt("championID");

				String op = Integer.toString(mmr) +"\t"+ Integer.toString(championID);
				champion.set(String.valueOf(op));
				write.set(champion);

				if(teamID==winner)
				{
				context.write(write, one);
				}
				else
				{
				context.write(write, zero);
				}
			}
		}
	}

	static class st4Reducer extends Reducer<Text, IntWritable, Text, IntWritable> {
		private IntWritable numGames = new IntWritable();

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

			Integer win = 0, total = 0, result =0;

			for (IntWritable val : values) {
				win += val.get();
				total = total + 1;
			}
			result = (win/total)*100;
			numGames.set(result);
			context.write(key, numGames);
		}
	}
}