【零基础学flink】flink DataStream API 详解

Flink中的DataStream主要用于实现数据流的转换操做（例如，过滤，更新状态，定义窗口，聚合）。最初能够从各类源（例如，消息队列，套接字流，文件）建立数据流（DataStream）。结果经过sink返回，sink操做主要有：将数据写入文件、标准输出（例如命令行终端）。Flink程序能够在各类环境中运行，独立运行或嵌入其余程序中。执行能够在本地JVM中执行，也能够在许多计算机集群上执行。ht

>>阅读原文<<