Flink的官 :https://flink.apache.org/
使用的软件:IntelliJ IDEA Community Edition
CoreAPI:
- DataSet:专门处理离线数据,给离线数据处理设计了更多有针对性的API. env:ExecutionEnvironment
- DataStream:一般用于处理流式数据,也可以处理离线数据env:StreamExecutionEnvironment
创建TransformationTest文件
练习一
将输入的数字均乘10
需要注意的点:
- 与之前那篇博客一样,很多代码不需要手敲,使用快捷键非常方便
- 着重要注意的是第三步,敲完”source.map(new M”后直接回车,能跳出”source.map(new MapFunction
“,括 中的”Integer”分别代表输入和输出值的类型,第一个之所以是Int是因为第二步中”source”就已经定义了是int,但是输出它不知道你需要什么,所以是”object”(注意第一个Integer有个蓝框)我们需要输入和输出都是int,所以先回车,将蓝框跳到”Object”,输入”Integer”,之后直接回车,下面的两行会直接跳出来,不需要手打(跳出下面两行不止一种方法,这一种感觉比较方便)
练习二
将字符串转化成 int 输出
需要注意的点:
- 我输入字符串时,每个数字的间隔是“, ”,除了逗 外还有空格,所以在第三步split将字符串拆开时也需要加个空格
练习三
每个数字累计求和
与练习二相比只在第三步底下增加了一点,其他不变,输出为15
练习四
将文件中的内容变成Tuple
声明:本站部分文章及图片源自用户投稿,如本站任何资料有侵权请您尽早请联系jinwei@zod.com.cn进行处理,非常感谢!