60-120-040-使用-Data Transformation简介

1.世界 1. flink代码基本架构 link 应用程序结构就是如上图所示： Source: 数据源，Flink 在流处理和批处理上的 source 大概有 4 类：基于本地集合的 source、基于文件的 source、基于网络套接字的 source、自定义的 source。自定义的 source 常见的有 Apache kafka、Amazon Kinesis Streams、RabbitM

>>阅读原文<<