5th June Batch

public class HelloWorld {

public static void main(String[] args) {

System.out.println(“Hello World!”);

}

}

curl -u admin:admin -X delete "http://192.168.0.12:8161/api/message/&clientId=consumerA"


import org.apache.hadoop.conf.Configured;

import org.apache.hadoop.util.Tool;

import java.io.BufferedInputStream;
import java.io.FileInputStream;
import java.io.InputStream;
import java.io.OutputStream;
import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.fs.FileSystem;
import org.apache.hadoop.fs.Path;
import org.apache.hadoop.io.IOUtils;
import org.apache.hadoop.util.ToolRunner;

public class HdfsWriter extends Configured implements Tool {
 
 public static final String FS_PARAM_NAME = "fs.defaultFS";
 
 public int run(String[] args) throws Exception {
 
 if (args.length < 2) {
 System.err.println("HdfsWriter [local input path] [hdfs output path]");
 return 1;
 }
 
 String localInputPath = args[0];
 Path outputPath = new Path(args[1]);

Configuration conf = getConf();
 conf.addResource(new Path("/home/amar/hadoop-2.6.0/etc/hadoop/hdfs-site.xml"));
 conf.addResource(new Path("/home/amar/hadoop-2.6.0/etc/hadoop/core-site.xml"));

System.out.println("configured filesystem = " + conf.get(FS_PARAM_NAME));
 FileSystem fs = FileSystem.get(conf);
 if (fs.exists(outputPath)) {
 System.err.println("output path exists");
 return 1;
 }
 
 OutputStream os = fs.create(outputPath);
 InputStream is = new BufferedInputStream(new FileInputStream(localInputPath));
 IOUtils.copyBytes(is, os, conf);
 return 0;
 }
 
 public static void main( String[] args ) throws Exception {
 int returnCode = ToolRunner.run(new HdfsWriter(), args);
 System.exit(returnCode);
 }
}

Input list 


Amar,M,15000
Arpitha,F,20000
Tejas,M,13000
Shaurya,M,19000
Rakshitha,F,18000
Prudhvi,M,23000
Srikhar,M,17000
Shreya,F,25000

Write the code and execute it on your laptop –

1. Using mapreduce, get the max temperature from the following input list –

233

245

123

2445

123

12

15

2. Using MapReduce from the following inout list – find the sum and average of the salaries genderwise.

Amar,M,15000

Arpitha,F,20000

Tejas,M,13000

Shaurya,M,19000

Rakshitha,F,18000

Prudhvi,M,23000

Srikhar,M,17000

Shreya,F,25000

Please attempt that at home and make sure that you do the coding as well – the difficulties we will see in tomorrow’s class.

#!/bin/bash
source ~/sourceme
mkdir -p ~/amar
rm ~/amar/in/woir/http/*.class
rm ~/amar/in/woir/http1/*.class
javac -d /home/amar/amar HelloWorld.java WOIR.java
java -cp /home/amar/amar:. in.woir.http.HelloWorld





package in.woir.http;
public class WOIR {
 private String batch;
 private String training_name ;
 public String getBatch(){
 return batch;
 }
 public String getTraining(){
 return training_name;
 }
 public String setTraining( String name){
 training_name = name ;
 }
 public String setBatch( String name){
 batch = name ;
 }
}

package in.woir.http;
import in.woir.http.*;
public class HelloWorld {

 public static void main(String[] args) {
 System.out.println("Hello, World");
 WOIR w = new WOIR();
 }

}

——————————————

public class HelloWorld {

public static void main(String[] args) {
// Prints “Hello, World” to the terminal window.
System.out.println(“Hello, World” + args[0]);
}

}
public class WOIR {
public void printme( ){
System.out.println(“Hello, World From WOIR”);
}
}