MapReduce算法（计算出10月1日这天超速（超过120）的车辆，超速的次数，超速的详细时间）

需求：计算出10月1日这天超速（超过120）的车辆，超速的次数，超速的详细时间

package CzC.demo02;import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.conf.Configured;
import org.apache.hadoop.fs.Path;
import org.apache.hadoop.io.LongWritable;
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.TextInputFormat;
import org.apache.hadoop.mapreduce.lib.output.TextOutputFormat;
import org.apache.hadoop.util.Tool;
import org.apache.hadoop.util.ToolRunner;import java.io.IOException;
import java.text.SimpleDateFormat;/*** Created by 一个蔡狗 on 2019/12/3.*/
public class TaxiCsDriver extends Configured implements Tool {@Overridepublic int run(String[] args) throws Exception {Configuration conf = new Configuration();Job job = Job.getInstance(conf, "text");job.setJarByClass(TaxiCsDriver.class);job.setInputFormatClass(TextInputFormat.class);TextInputFormat.addInputPath(job, new Path("E:\\2019-BUPT\\企业需求实战\\01\\20121001"));job.setMapperClass(TaxiCsMapper.class);job.setMapOutputKeyClass(Text.class);job.setMapOutputValueClass(Text.class);job.setReducerClass(TaxiCsReducer.class);job.setOutputKeyClass(Text.class);job.setOutputValueClass(Text.class);job.setOutputFormatClass(TextOutputFormat.class);TextOutputFormat.setOutputPath(job, new Path("E:\\2019-BUPT\\企业需求实战\\01\\超速次数"));boolean b = job.waitForCompletion(true);return b ? 0 : 1;}public static void main(String[] args) throws Exception {ToolRunner.run(new TaxiCsDriver(), args);}static class TaxiCsMapper extends Mapper<LongWritable, Text, Text, Text> {private SimpleDateFormat df = new SimpleDateFormat("YYYY-MM-dd");@Overrideprotected void map(LongWritable key, Text value, Context context) throws IOException, InterruptedException {String[] split = value.toString().split(",");if (split.length >= 7) {if (Long.parseLong(split[6]) > 120) {//10月1日String date = split[3];if (date.substring(0, 8).endsWith("1001")) {context.write(new Text(split[0]), new Text(date));}}}}}static class TaxiCsReducer extends Reducer<Text, Text, Text, Text> {//        车机标识,触发事件,运营状态,GPS时间,GPS经度,GPS纬度,GPS速度,GPS方向,GPS状态@Overrideprotected void reduce(Text key, Iterable<Text> values, Context context) throws IOException, InterruptedException {long sum = 0;for (Text value : values) {context.write(new Text("车辆标识" + key), new Text("车辆时间" + value));sum++;}context.write(new Text("车辆标识" + key ), new Text("\r\t超时120的次数"+sum));}}}

MapReduce算法（计算出10月1日这天超速（超过120）的车辆，超速的次数，超速的详细时间）相关推荐

MapReduce算法（计算出10月1日这天全天停运的车辆，）
需求 :计算出10月1日这天全天停运的车辆 package CzC.demo03;import CzC.demo02.TaxiCsDriver; import org.apache.hadoop.co ...
MapReduce算法（计算出10月1日这天载客次数超过10次的车辆，载客总次数，载客详细时间。）
需求 :计算出10月1日这天载客次数超过10次的车辆,载客总次数,载客详细时间. package CzC.demo03;import CzC.demo02.TaxiCsDriver; import o ...
python 判断该地址文件创建时间2020年10月14日14时25分32秒文件最后一次访问时间文件最后一次修改时间
#1.判断该地址 #1.文件名 #2.文件路径 #3.文件扩展名 #4.文件创建时间2020年10月14日14时25分32秒 #5.文件最后一次访问时间 #6.文件最后一次修改时间 #7.文件的大小( ...
ff14服务器维护时间,《FF14》10月15日国服维护到几点 5.0新版本更新维护公告
最终幻想14的国服将会在10月15日这天进行更新维护,并且也公布了最新5.0的更新笔记全部内容汇总以及具体的更新时间,下面就来为大家详细的介绍一下最终幻想14的更新维护公告. 亲爱的冒险者: 我们将于 ...
神雕侠侣手游服务器维护,《神雕侠侣》10月25日更新维护公告
亲爱的玩家朋友: 为了给您提供更好的游戏体验,所有服务器将于2012年10月25日早上8:00点进行停机维护,所有服务器预计维护完成时间为12:00,具体开服时间以官方信息为准.请各位玩家提前处理好游 ...
问道神兵天降服务器维护,《古剑奇谭网络版》10月22日更新维护公告
原标题:<古剑奇谭网络版>10月22日更新维护公告本周更新内容职业调整概述:本次进行了部分斗法数值调整.本月内将不再进行技能机制及数值调整,优化及技能问题修复将持续进行. >& ...
【历史上的今天】10 月 8 日：Netflix 创始人诞生；反向传播算法经典论文发表；Android 4.0 发布
整理 | 王启隆透过「历史上的今天」,从过去看未来,从现在亦可以改变未来. 今天是 2022 年 10 月 8 日,家喻户晓的三国时期杰出人物诸葛亮在今天逝世,他对丰功伟绩被许多文献记载,他对巴蜀的 ...
计算任意一天距1949年10月1日的天数
/** * @version * @author JavaHanlei * 计算任意一天距1949年10月1日的天数: * */ import java.util.Scanner; public cl ...
2016年10月9日星期日 --出埃及记 Exodus 18:20
2016年10月9日星期日 --出埃及记 Exodus 18:20 Teach them the decrees and laws, and show them the way to live an ...

MapReduce算法（计算出10月1日这天超速（超过120）的车辆，超速的次数，超速的详细时间）

需求：计算出10月1日这天超速（超过120）的车辆，超速的次数，超速的详细时间

MapReduce算法（计算出10月1日这天超速（超过120）的车辆，超速的次数，超速的详细时间）相关推荐

最新文章

热门文章

MapReduce算法（计算出10月1日这天超速（超过120）的车辆，超速的次数，超速的详细时间）

需求 ：计算出10月1日这天超速（超过120）的车辆，超速的次数，超速的详细时间

MapReduce算法（计算出10月1日这天超速（超过120）的车辆，超速的次数，超速的详细时间）相关推荐

最新文章

热门文章

需求：计算出10月1日这天超速（超过120）的车辆，超速的次数，超速的详细时间