1. 创建执行环境2. Source3. Transform4. Flink支持的数据类型5. Sink 1. 创建执行环境本地和远程环境切换不方便,所以Flink直接将环境封装。 2. Source 从集合中读取数据 从文件中读取数据 从Kafka中读取数据 自定义测试数据源 3. Transform回头再看 4. Flink支持的数据类型回头再看 5. Sink