开发者社区> 问答> 正文

Flink 流处理API的编程的Source流程是什么?

Flink 流处理API的编程的Source流程是什么?

展开
收起
芯在这 2021-12-09 18:55:43 476 0
1 条回答
写回答
取消 提交回答
  • (1)从集合读取数据

    val stream = env.fromCollection(List("a","b","c")) 1

    (2)从文件读取数据

    val stream = env.readTextFile("YOUR_FILE_PATH") 1

    (3)kafka消息队列的数据作为来源

      需要引入kafka连接器的依赖:

    org.apache.flink flink-connector-kafka-0.11_2.11 1.10.0

      (4)自定义Source

        除了以上的source数据来源,我们还可以自定义source。需要做的,只是传入一个SourceFunction就可以。

    2021-12-09 18:56:02
    赞同 展开评论 打赏
问答排行榜
最热
最新

相关电子书

更多
Flink CDC Meetup PPT - 龚中强 立即下载
Flink CDC Meetup PPT - 王赫 立即下载
Flink CDC Meetup PPT - 覃立辉 立即下载