Flink DataStream API编程

DataStream API Flink 的DataStream程序四实现数据流转换的常规程序(例如L过滤, 更新状态,定义窗口,聚合).最初从各类源（例如，消息队列，套接字流，文件）建立数据流。结果经过接收器返回，接收器能够例如将数据写入文件或标准输出（例如命令行终端）。Flink程序能够在各类环境中运行，独立运行或嵌入其余程序中。执行能够在本地JVM中执行，也能够在许多计算机的集群上执行。ja

>>阅读原文<<