a1.sources = r1 a1.sinks = k1 a1.channels = c1 # Describe/configure the source a1.sources.r1.type = netcat a1.sources.r1.bind = localhost a1.sources.r... ...
分类:
Web程序 时间:
2017-05-17 00:49:15
阅读次数:
214
a1.sources = r1 a1.sinks = k1 a1.channels = c1 # Describe/configure the source a1.sources.r1.type = netcat a1.sources.r1.bind = localhost a1.sources.r... ...
分类:
Web程序 时间:
2017-05-17 00:47:42
阅读次数:
226
环境介绍: 主服务器ip:192.168.80.128 1、准备apache-flume-1.7.0-bin.tar文件 2、上传到master(192.168.80.128)服务器上 3、解压apache-flume-1.7.0-bin.tar 4、进入到Flume的配置文件目录 5、修改apac ...
分类:
Web程序 时间:
2017-05-17 00:40:50
阅读次数:
230
a1.sources = r1 a1.sinks = k1 k2 a1.channels = c1 c2 # Describe/configure the source a1.sources.r1.type = netcat a1.sources.r1.bind = localhost a1.sou... ...
分类:
Web程序 时间:
2017-05-17 00:40:08
阅读次数:
205
倒排索引 (就是key和Value对调的显示结果) 一、需求:下面是用户播放音乐记录,统计歌曲被哪些用户播放过 tom LittleApple jack YesterdayOnceMore Rose MyHeartWillGoOn jack LittleApple John MyHeartWillG ...
分类:
其他好文 时间:
2017-05-08 01:22:28
阅读次数:
215
1、数据准备 使用MapReduce计算age.txt中年龄最大、最小、均值name,min,max,countMike,35,20,1Mike,5,15,2Mike,20,13,1Steven,40,20,10Ken,28,68,1Ken,14,198,10Cindy,32,31,100 2、预期 ...
分类:
其他好文 时间:
2017-05-08 00:28:50
阅读次数:
527
1、数据准备: Mike,35 Steven,40 Ken,28 Cindy,32 2、预期结果 Max 40 Min 28 Avg 33 3、MapReduce代码如下 4、注意事项 因为输出的结果和Key没有关系,所以在map阶段要固定一个Key即可。 ...
分类:
其他好文 时间:
2017-05-08 00:23:54
阅读次数:
267
环境介绍: 主服务器ip:192.168.80.128(master) NameNode SecondaryNameNode ResourceManager 从服务器ip:192.168.80.129(slave1) DataNode NodeManager 从服务器ip: 192.168.80.1 ...
分类:
其他好文 时间:
2017-05-08 00:22:32
阅读次数:
288
一、准备运行所需Jar包 1)avro-1.7.4.jar 2)commons-cli-1.2.jar 3)commons-codec-1.4.jar 4)commons-collections-3.2.1.jar 5)commons-compress-1.4.1.jar 6)commons-con ...
Hadoop研发在java环境的拓展 一 背景 由于一直使用hadoop streaming形式编写mapreduce程序,所以目前的hadoop程序局限于python语言。下面为了拓展java语言研发,本次实验使用window系统,maven打包,centos系统mapr环境运行。 二 步骤 1 ...
分类:
编程语言 时间:
2016-07-21 15:00:04
阅读次数:
209