第一个spark 入门级 pv计算
2016-01-08 16:31
302 查看
开发第一个入门级spark 应用程序
第一测试数据:
A0008062015_48c47a4cf0a4f79f pConnection_18 1440648000.043241000 1540648000.045089000 211.88.25.111 17848 0 0 211.88.25.173 8888 7 295 noabort 0.000000000 0.000000000 0 0 ---SF-|http://localhost
A0008062015_48c47a4cf0a4f79f pConnection_18 1440648000.043241000 1640648000.045089000 211.88.25.111 17848 0 0 212.88.25.173 8888 7 295 noabort 0.000000000 0.000000000 0 0 ---SF-|url
A0008062015_48c47a4cf0a4f79f pConnection_18 1440648000.043241000 1440648000.045089000 211.88.25.111 17848 0 0 213.88.25.173 8888 7 295 noabort 0.000000000 0.000000000 0 0 ---SF-|url
A0008062015_48c47a4cf0a4f79f pConnection_18 1440648000.043241000 1440648000.045089000 211.88.25.111 17848 0 0 214.88.25.173 8888 7 295 noabort 0.000000000 0.000000000 0 0 ---SF-|url
A0008062015_48c47a4cf0a4f79f pConnection_18 1440648000.043241000 1440648000.045089000 211.88.25.111 17848 0 0 215.88.25.173 8888 7 295 noabort 0.000000000 0.000000000 0 0 ---SF-|url
A0008062015_48c47a4cf0a4f79f pConnection_18 1440648000.043241000 1440648000.045089000 211.88.25.111 17848 0 0 216.88.25.173 8888 7 295 noabort 0.000000000 0.000000000 0 0 ---SF-|url
A0008062015_48c47a4cf0a4f79f pConnection_18 1440648000.043241000 1440648000.045089000 211.88.25.111 17848 0 0 217.88.25.173 8888 7 295 noabort 0.000000000 0.000000000 0 0 ---SF-|url
A0008062015_48c47a4cf0a4f79f pConnection_18 1440648000.043241000 1440648000.045089000 211.88.25.111 17848 0 0 218.88.25.173 8888 7 295 noabort 0.000000000 0.000000000 0 0 ---SF-|url
A0008062015_48c47a4cf0a4f79f pConnection_18 1440648000.043241000 1440648000.045089000 211.88.25.111 17848 0 0 211.88.25.173 8888 7 295 noabort 0.000000000 0.000000000 0 0 ---SF-|url
A0008062015_48c47a4cf0a4f79f pConnection_18 1440648000.043241000 1440648000.045089000 211.88.25.111 17848 0 0 211.88.25.173 8888 7 295 noabort 0.000000000
第二程序:
主函数入口
3 打成jar 文件运行。 File----project Structure-----Arcfacts 进行打包操作 详细如下图所示:
然后点击Apply 并ok。
4 编译程序
4 (spark 集群启动的环境下)
在终端输入: spark-submit --master spark://192.168.1.118:7077 --name WorldCount --class com.hq.WorldCount --executor-memory 2G --total-executor-cores 2 ~/spark_test/spark_yw.jar hdfs://192.168.1.118:9000/yw/b.txt hdfs://192.168.1.118:9000/yw/vvv
看到如下结果。就ok了。
第一测试数据:
A0008062015_48c47a4cf0a4f79f pConnection_18 1440648000.043241000 1540648000.045089000 211.88.25.111 17848 0 0 211.88.25.173 8888 7 295 noabort 0.000000000 0.000000000 0 0 ---SF-|http://localhost
A0008062015_48c47a4cf0a4f79f pConnection_18 1440648000.043241000 1640648000.045089000 211.88.25.111 17848 0 0 212.88.25.173 8888 7 295 noabort 0.000000000 0.000000000 0 0 ---SF-|url
A0008062015_48c47a4cf0a4f79f pConnection_18 1440648000.043241000 1440648000.045089000 211.88.25.111 17848 0 0 213.88.25.173 8888 7 295 noabort 0.000000000 0.000000000 0 0 ---SF-|url
A0008062015_48c47a4cf0a4f79f pConnection_18 1440648000.043241000 1440648000.045089000 211.88.25.111 17848 0 0 214.88.25.173 8888 7 295 noabort 0.000000000 0.000000000 0 0 ---SF-|url
A0008062015_48c47a4cf0a4f79f pConnection_18 1440648000.043241000 1440648000.045089000 211.88.25.111 17848 0 0 215.88.25.173 8888 7 295 noabort 0.000000000 0.000000000 0 0 ---SF-|url
A0008062015_48c47a4cf0a4f79f pConnection_18 1440648000.043241000 1440648000.045089000 211.88.25.111 17848 0 0 216.88.25.173 8888 7 295 noabort 0.000000000 0.000000000 0 0 ---SF-|url
A0008062015_48c47a4cf0a4f79f pConnection_18 1440648000.043241000 1440648000.045089000 211.88.25.111 17848 0 0 217.88.25.173 8888 7 295 noabort 0.000000000 0.000000000 0 0 ---SF-|url
A0008062015_48c47a4cf0a4f79f pConnection_18 1440648000.043241000 1440648000.045089000 211.88.25.111 17848 0 0 218.88.25.173 8888 7 295 noabort 0.000000000 0.000000000 0 0 ---SF-|url
A0008062015_48c47a4cf0a4f79f pConnection_18 1440648000.043241000 1440648000.045089000 211.88.25.111 17848 0 0 211.88.25.173 8888 7 295 noabort 0.000000000 0.000000000 0 0 ---SF-|url
A0008062015_48c47a4cf0a4f79f pConnection_18 1440648000.043241000 1440648000.045089000 211.88.25.111 17848 0 0 211.88.25.173 8888 7 295 noabort 0.000000000
第二程序:
主函数入口
3 打成jar 文件运行。 File----project Structure-----Arcfacts 进行打包操作 详细如下图所示:
然后点击Apply 并ok。
4 编译程序
4 (spark 集群启动的环境下)
在终端输入: spark-submit --master spark://192.168.1.118:7077 --name WorldCount --class com.hq.WorldCount --executor-memory 2G --total-executor-cores 2 ~/spark_test/spark_yw.jar hdfs://192.168.1.118:9000/yw/b.txt hdfs://192.168.1.118:9000/yw/vvv
看到如下结果。就ok了。
相关文章推荐
- 静态链表例题
- MFC入门教程
- 数列排序
- 数组去重Array
- java 中的JDK封装的数据结构和算法解析(集合类)----顺序表 List 之 ArrayList
- JDBC的那点事之DatabaseMetaData之获取表的所有列名
- IIS应用程序池死报“数据字段包含错误号” 的解决办法
- iOS 记录系统运行日志到指定文件目录
- 多线程程序里不准使用fork
- Base64编码
- 正则表达式
- JAXB实现xml与javabean的转换
- 22
- iOS开发之UICollectionView(一)
- COCOS-HTML5-3.9版本学习(四)chipmunk物理引擎的测试
- URLDecoder.decode(String str,String charSet)的大致实现原理
- UITextView高度根据内容变化
- 网页代码测试工具集合
- 大端小端
- 2015年就这样过去了