fork download
copy 
  1. import java.io.IOException; 
  2. import java.util.Iterator; 
  3. import org.apache.hadoop.fs.Path; 
  4. import org.apache.hadoop.io.LongWritable; 
  5. import org.apache.hadoop.io.Text; 
  6. import org.apache.hadoop.mapreduce.lib.input.FileInputFormat;  
  7. import org.apache.hadoop.mapreduce.lib.output.FileOutputFormat; 
  8. import org.apache.hadoop.mapreduce.lib.output.TextOutputFormat;  
  9. import org.apache.hadoop.mapreduce.lib.input.TextInputFormat; 
  10. import org.apache.hadoop.mapreduce.Job; 
  11. import org.apache.hadoop.mapreduce.Mapper;  
  12. import org.apache.hadoop.mapreduce.Reducer;  
  13. import org.apache.hadoop.conf.Configuration; 
  14. public class MyMaxMin { 
  15. public static class MaxTemperatureMapper extends Mapper<LongWritable, Text, Text, Text> 
  16. { 
  17. public void map(LongWritable arg0, Text Value, Context context)throws IOException, 
  18. InterruptedException 
  19. { 
  20. String line = Value.toString(); if (!(line.length() == 0)){ 
  21. String date = line.substring(6, 14);  //date 
  22. float temp_Max = Float.parseFloat(line.substring(39, 45).trim()); 
  23. float temp_Min = Float.parseFloat(line.substring(47, 53).trim());  
  24. if (temp_Max > 35.0){ 
  25. context.write(new Text("Hot Day " + date), new Text(String.valueOf(temp_Max))); 
  26. } 
  27. if (temp_Min < 10) 
  28. { 
  29. context.write(new Text("Cold Day " + date),new Text(String.valueOf(temp_Min))); 
  30. } 
  31. } 
  32. } //MAP - CLOSE 
  33. } //CLASS - CLOSE 
  34. public static class MaxTemperatureReducer extends Reducer<Text, Text, Text, Text> 
  35. { 
  36. public void reduce(Text Key, Iterator<Text> Values, Context context)throws IOException, 
  37. InterruptedException 
  38. { 
  39. String temperature = Values.next().toString(); 
  40. context.write(Key, new Text(temperature)); 
  41. } 
  42. } 
  43. public static void main(String[] args) throws Exception 
  44. { 
  45. Configuration conf = new Configuration();  
  46. Job job = new Job(conf, "weather example"); 
  47. job.setJarByClass(MyMaxMin.class); //Assigning the driver class name 
  48. job.setMapOutputKeyClass(Text.class); //Key type coming out of mapper 
  49. job.setMapOutputValueClass(Text.class); //value type coming out of mapper 
  50. job.setMapperClass(MaxTemperatureMapper.class); 
  51. job.setReducerClass(MaxTemperatureReducer.class); 
  52. job.setInputFormatClass(TextInputFormat.class); 
  53. job.setOutputFormatClass(TextOutputFormat.class); 
  54. Path OutputPath = new Path(args[1]);  
  55. FileInputFormat.addInputPath(job, new Path(args[0]));  
  56. FileOutputFormat.setOutputPath(job, new Path(args[1])); 
  57. OutputPath.getFileSystem(conf).delete(OutputPath); 
  58. System.exit(job.waitForCompletion(true) ? 0 : 1); 
  59. } 
  60. } 
  61.  
Success #stdin #stdout #stderr 0s 5288KB
comments (?)
stdin
copy 
Standard input is empty
stdout
copy 
Standard output is empty
stderr
copy 
Error: near line 1: near "import": syntax error
Error: near line 2: near "import": syntax error
Error: near line 3: near "import": syntax error
Error: near line 4: near "import": syntax error
Error: near line 5: near "import": syntax error
Error: near line 6: near "import": syntax error
Error: near line 7: near "import": syntax error
Error: near line 8: near "import": syntax error
Error: near line 9: near "import": syntax error
Error: near line 10: near "import": syntax error
Error: near line 11: near "import": syntax error
Error: near line 12: near "import": syntax error
Error: near line 13: near "import": syntax error
Error: near line 14: near "public": syntax error
Error: near line 23: near "float": syntax error
Error: near line 24: near "if": syntax error
Error: near line 26: unrecognized token: "}"
Error: near line 30: unrecognized token: "}"
Error: near line 40: near "context": syntax error
Error: near line 41: unrecognized token: "}"
Error: near line 46: near "Job": syntax error
Error: near line 47: near "job": syntax error
Error: near line 51: near "job": syntax error
Error: near line 52: near "job": syntax error
Error: near line 53: near "job": syntax error
Error: near line 54: near "Path": syntax error
Error: near line 55: near "FileInputFormat": syntax error
Error: near line 56: near "FileOutputFormat": syntax error
Error: near line 57: near "OutputPath": syntax error
Error: near line 58: near "System": syntax error
Error: near line 59: unrecognized token: "}"
https://ideone.com/D0CGj8
language:
SQLite (sqlite 3.27.2)
created:
12 days ago
visibility:
public

Share or Embed source code

Discover > Sphere Engine API

The brand new service which powers Ideone!

Discover > IDE Widget

Widget for compiling and running the source code in a web browser!