flink之source

Posted suspring

tags:

篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了flink之source相关的知识,希望对你有一定的参考价值。

1.集合source

 技术图片

 

 2.hdfs source

技术图片

 

 3.kafka 单value source

技术图片

 

 4. kafka 键值对source

技术图片

 

 技术图片

 

 启动生产者

技术图片

 5.自定义source

  技术图片

 

以上是关于flink之source的主要内容,如果未能解决你的问题,请参考以下文章

Flink Flink 源码之 Buffer Timeout优化

大数据计算引擎之Flink Flink状态管理和容错

Flink on Yarn三部曲之三:提交Flink任务

Flink 最佳实践之 通过 TiCDC 将 TiDB 数据流入 Flink

Flink系列之:基于scala语言实现flink实时消费Kafka Topic中的数据

Flink实践|Apache Flink 误用之痛