Flink初次练习（Transformation）

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