Flink实战(三) - 编程范式及核心概念

1 基本的 API 概念 Flink程序是实现分布式集合转换的常规程序（例如，过滤，映射，更新状态，加入，分组，定义窗口，聚合）。最初从源建立集合（例如，经过从文件，kafka主题或从本地的内存集合中读取）。结果经过接收器返回，接收器能够例如将数据写入（分布式）文件或标准输出（例如，命令行终端）。 Flink程序能够在各类环境中运行，独立运行或嵌入其余程序中。执行能够在本地JVM中执行，也能够在许

>>阅读原文<<