flink自定義source與自定義sink

flink自定義source與自定義sink flink 的source和sink即數據源和數據接收器。在原生的flink中提供了一些經常使用的數據源鏈接器，可是在平常開發中咱們所使用的數據源和持久化工具是多種多樣的，flink提供的 source和sink就不能知足咱們的需求，這時就須要使用flink提供的接口自定義source和sink。java flink 提供的source 和 sink

>>阅读原文<<