文章浏览阅读288次。Flink 做为一款流式计算框架，它可用来做批处理，即处理静态的数据集、历史的数据集；也可以用来做流处理，即实时的处理些实时数据流，实时的产生数据流结果，只要数据源源不断的过来，Flink 就能够一直计算下去，这个 Data Sources 就是数据的来源地。一. 基于集合1. fromCollection(Collection) -从 Collection 创建数据流。集合中的所有元素类型必须相同。1. 代码代码package com.hjf.dataSourceimport or._新一代大数据计算引擎 flink从入门到实战 (热点内容更新) 百度网盘