四、流处理API

1. 创建执行环境

本地和远程环境切换不方便，所以Flink直接将环境封装。

2. Source

1. 从集合中读取数据

1. 从文件中读取数据

1. 从Kafka中读取数据

1. 自定义测试数据源

3. Transform

回头再看

4. Flink支持的数据类型

回头再看

5. Sink