Flink DataStream API编程入门

作者：酷酷是懒虫 | 2024-08-02 07:37:35

踩

什么是数据流

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

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

声明：本文内容由网友自发贡献，转载请注明出处：【wpsshop】