首页
学习
活动
专区
工具
TVP
发布
精选内容/技术社群/优惠产品,尽在小程序
立即前往
您找到你想要的搜索结果了吗?
是的
没有找到

Flink 程序结构 上篇

欢迎来到 KK 大数据,今天分享的主题是:Flink 程序结构 (这两天公司有发布项目,拖更了两天, 甚是对不住观众老爷 ) 我们还是从wordcount程序说起 下面是一段使用 Flink 实现的 WordCount...下面依次来讲这五个步骤(分两篇文章讲完) (1)Execution Environment 运行 Flink 程序第一步就是要获取相应的执行环境,决定程序在什么地方执行(本地或者集群上),同时不同的运行环境决定了应用的类型...然后将定义好的 Function 应用在对应的算子中即可 (1)通过创建 Class 实行 Function 接口 val counts : DataStream[(String,Int)] = text.map...好,今天就讲到这,下一次讲 Flink 程序结构的 分区 key 指定,输出结果,程序触发 。 观众老爷们,下次见! 公众号ID:kkbigdata

60340
领券