-
Notifications
You must be signed in to change notification settings - Fork 0
/
Query5Mapper.java
32 lines (20 loc) · 1 KB
/
Query5Mapper.java
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
package Query5;
import org.apache.hadoop.io.IntWritable;
import org.apache.hadoop.io.LongWritable;
import org.apache.hadoop.io.Text;
import org.apache.hadoop.mapred.MapReduceBase;
import org.apache.hadoop.mapred.OutputCollector;
import org.apache.hadoop.mapred.Reporter;
import org.apache.hadoop.mapred.Mapper;
import java.io.IOException;
public class Query5Mapper extends MapReduceBase implements Mapper<LongWritable, Text, Text, IntWritable> {
private Text yearOriginDest = new Text();
private IntWritable one = new IntWritable(1);
public void map(LongWritable key, Text value, OutputCollector<Text, IntWritable> output, Reporter reporter) throws IOException {
String[] line = value.toString().split(",");
if not (line[0].equals("Year") || line[0].equals("NA") || line[16].equals("NA") || line[17].equals("NA")) {
yearOriginDest.set("Year: " + line[0] + " Origin: " + line[16] + " Destination: " + line[17]);
output.collect(yearOriginDest, one);
}
}
}