标签： Flink Source

自定义Source，官网有一个比较好的例子，用于生成信用卡交易数据，我们简单来看一下源码。源码主要的功能类有两… 继续阅读 Flink从入门到实战四[DataStream API]-11-Source-官网反欺诈自动生成Demo源码解读

自定义Source，最重要的一个步骤就是实现SourceFunction接口，定义一个Source类。在这个自… 继续阅读 Flink从入门到实战四[DataStream API]-10-Source-自定义数据源

pom文件： 安装 RabbitMQ略 RabbitMQ SourceRMQSource 负责从 Rabbit… 继续阅读 Flink从入门到实战四[DataStream API]-9-Source-从MQ中读取数据

基于Socket的数据源，在之前的demo中已经演示了，我们直接看代码： 测试数据 输出结果

Flink 从文件中获取数据 输出结果：

Flink 从集合中获取数据，我们直接看代码： 输出结果：