（1）代码示例 1 import org.apache.flink.streaming.api.scala._ 2 3 object StreamWordCount { 4 def main(args:Array[String]):Unit={ 5 //创建流处理的执行环境 6 val env=St ...
分类：
其他好文 时间：
2020-05-26 22:09:36
阅读次数：
92
package cn.itcast.hadoop.mr;import java.io.IOException;import org.apache.hadoop.conf.Configuration;import org.apache.hadoop.fs.Path;import org.apache. ...
分类：
其他好文 时间：
2020-02-02 23:19:55
阅读次数：
98
简述 WordCount（单词计数）作为大数据体系的标准示例，一直是入门的经典案例，下面用java和scala实现Flink的WordCount代码； 采用IDEA + Maven + Flink 环境；文末附 pom 文件和相关技术点总结； Java批处理版本 运行输出结果如下： Java流处理版 ...
分类：
编程语言 时间：
2019-11-28 19:14:57
阅读次数：
101
在没有安装flink的情况下，试运行 wordcount 代码。代码如下： package bigdata.batch; import org.apache.flink.api.common.functions.FlatMapFunction; import org.apache.flink.api ...
分类：
其他好文 时间：
2019-11-22 01:09:59
阅读次数：
93
不知道为啥不是很想学习MapReduce方面的知识，不过现在这么想可能过段时间还是免不了去学，这边先记录下一个MapReduce的实例wordcount代码。 1、 pom.xml： 6、结果查询： ...
分类：
其他好文 时间：
2018-10-27 13:18:48
阅读次数：
140
1.项目地址： 开发者：201631062515 201631062415 码云地址：https://gitee.com/heshuxiang/WordCount/tree/master 2.项目需求 对程序设计语言源文件统计字符数、单词数、行数，统计结果以指定格式输出到默认文件中，以及其他扩展功能 ...
分类：
其他好文 时间：
2018-10-21 21:48:40
阅读次数：
172
1.项目地址：https://gitee.com/wajp/WordCount 2.代码： 3.测试 4.参考文献链接 【1】http://www.cnblogs.com/xinz/p/5044037.html 【2】https://www.jianshu.com/p/5323bca00825 ...
分类：
其他好文 时间：
2018-09-25 01:28:58
阅读次数：
208
https://gitee.com/Siy1015/WordCount 代码实现 import java.io.BufferedReader; import java.io.BufferedWriter; import java.io.File; import java.io.FileReader; ...
分类：
其他好文 时间：
2018-09-25 01:10:27
阅读次数：
177
正则表达式，大概是用来筛选符合题目要求的单词，还没看到这里的代码 args参数，不太懂main中判断这个的意义 异常检测处理机制，还没实际看看差别 try{ //需要检测的代码 }catch(exception e){ //处理异常代码} ...
分类：
其他好文 时间：
2018-09-13 22:38:56
阅读次数：
164
执行wordcount 代码 package org.apache.hadoop.examples; import java.io.IOException; import java.util.Iterator; import java.util.StringTokenizer; import org ...
分类：
其他好文 时间：
2018-05-24 23:07:58
阅读次数：
307
