龙空技术网

新增访客数量MR统计之MR数据输出到MySQL

分享电脑学习 249

前言:

今天大家对“mysql查询输出到文件”都比较关注,咱们都需要分析一些“mysql查询输出到文件”的相关资讯。那么小编在网上搜集了一些对于“mysql查询输出到文件””的相关文章,希望你们能喜欢,看官们一起来学习一下吧!

承接上一个文档《新增访客数量MR统计之数据库准备》

首先将MR数据输出到MySQL

创建TransformerOutputFormat和ICollector,文件位置如下:

完成ICollector的代码

完成TransformerOutputFormat代码如下:

自定义的数据输出格式器,要求: 1. 数据输出到mysql 2. 要体现代码的公用性

接着下面的部分

使用的是FileOutputFormat中默认的方式

自定义的具体将reducer输出数据输出到mysql表的输出器

构造方法

Write方法

Close方法

修改Runner类,配置方法加入所需要的配置文件

将reduce的输出类型更改为MapWritableValue

job.setOutputValueClass(MapWritableValue.class);

给定自定义的outputformat类

job.setOutputFormatClass(TransformerOutputFormat.class);

如果全改了,可以测试运行下

先看下HDFS上有没有数据

下载下来查看下

再看下数据库有没有数据,发现有数据,本地环境就没有问题了,现在看下打包到Linux上之后是否有问题。

先打包程序运行一下

运行jar包,查看屏幕信息

查看屏幕输出信息

查看HDFS上是有数据的

代码已经上传到云盘了,可以下载调试一下

标签: #mysql查询输出到文件