Flink DataStream API编程入门

目录

什么是数据流

Flink程序的剖析

获取执行环境

加载/创建初始数据

指定对该数据的转换

指定把计算结果放在哪里

触发程序执行

案例

        Flink中的数据流（DataStream）程序是在数据流上实现转换（transformations）的常规程序（例如，过滤，更新状态，定义窗口，聚合）。数据流最初是从各种来源（例如，消息队列、套接字流、文件）创建的。结果通过接收器（Sink）返回，例如，接收器可以将数据写入文件或标准输出（例如命令行终端）。Flink程序可以在各种上下文中运行，可以独立运行，也可以嵌入到其他程序中。执行可以在本地JVM中进行，也可以在多台机器组成的集群中进行。

        为了创建您自己的Flink数据流程序，我们鼓励您从Flink程序的剖析（anatomy of a Flink Program）开始，并逐渐添加您自己的流转换（stream transformations）。其余部分作为附加操作和高级特性的参考。