Flink 实时计算 - 进阶篇（如何自定义 Data Source 与 Data Sink）

第1关：Flink 实现自定义 Data Source (一)任务描述

本关任务：实现一个输入为 0 到 99 的 Data Source。

相关知识
为了完成本关任务，你需要掌握：如何自定义 Data Source。编程要求
根据提示，在右侧编辑器补充代码，完成一个输入为 0 到 99 的 Data Source。

import org.apache.flink.streaming.api.functions.source.RichSourceFunction;
/*** ━━━━━━神兽出没━━━━━━* 　　　┏┓　　　┏┓* 　　┏┛┻━━━┛┻┓* 　　┃　　　　　　　┃* 　　┃　　　━　　　┃* 　　┃　┳┛　┗┳　┃* 　　┃　　　　　　　┃* 　　┃　　　┻　　　┃* 　　┃　　　　　　　┃* 　　┗━┓　　　┏━┛* 　　　　┃　　　┃神兽保佑, 永无BUG!* 　　　　 ┃　　　┃Code is far away from bug with the animal protecting* 　　　　┃　　　┗━━━┓* 　　　　┃

Flink 实时计算 - 进阶篇（如何自定义 Data Source 与 Data Sink）相关推荐

Flink 实时计算 - 维表 Join 解读
Flink 实时计算 - 维表 Join 解读前言 Flink 1.9 版本可以说是一个具有里程碑意义的版本,其内部合入了很多 Blink Table/SQL 方面的功能,同时也开始增强 Flink ...
传统金融业务场景下Flink实时计算的探索与实践？ by鸣宇淳
超长文警告!本文7000字,含架构图和各种解决方案的尝试,以及详细代码.,最后还有电子书和各种分享ppt下载,请在wifi下观看.土豪随意我是鸣宇淳,一个大数据架构师.今天给大家分享一下我在传统金融 ...
Flink 实时计算在微博的应用
简介: 微博通过将 Flink 实时流计算框架跟业务场景相结合,在平台化.服务化方面做了很大的工作,在开发效率.稳定性方面也做了很多优化.我们通过模块化设计和平台化开发,提高开发效率. 微博机器学习研 ...
SpringBoot学习之旅(七)---JPA进阶篇之自定义查询、修改、分页
文章目录前言源码下载其他文章查询关键字自定义Select和Update 分页及自定义分页自定义分页分页查询的业务代码前言前一节SpringBoot学习之旅(六)-JPA操作MySql ...
Flink——实时计算引擎
Flink介绍框架和分布式流处理引擎,应用于持续生成新数据的场景,如:电商促销时的实时交易总额榜,TOP5最受欢迎的产品等等,简单描述如下: 数据实时采集-->数据实时计算-->数据实时 ...
Flink实时计算指标对数方案
对于一个实时数据产品人员.或者开发人员来说,产品上展示的实时数据,pv.uv.gmv等等,怎么知道这些数据是不是正确的呢?当其他的小组开发的产品的数据(或者其他的数据提供方)又是另外一个数字,那么究竟 ...
Flink实时计算斗鱼某直播间弹幕发言数TopN
先获取斗鱼直播间弹幕,由kafka发送至flink消费,每隔10min输出最近1H内发言数量前10的用户名. 主要pom依赖 <dependency><groupId>org. ...
【硬刚大数据】Flink在实时在实时计算平台和实时数仓中的企业级应用小结
欢迎关注博客主页:https://blog.csdn.net/u013411339 欢迎点赞.收藏.留言 ,欢迎留言交流! 本文由[王知无]原创,首发于 CSDN博客! 本文首发CSDN论坛,未经过官 ...
汽车之家基于 Flink 的实时计算平台 3.0 建设实践
▼ 关注「Apache Flink」,获取更多技术干货 ▼ 摘要:本文整理自汽车之家实时计算平台负责人邸星星在 Flink Forward Asia 2021 平台建设专场的演讲.主要内容包括: 应用 ...
Flink在实时在实时计算平台和实时数仓中的企业级应用小结
点击上方蓝色字体,选择"设为星标" 回复"资源"获取更多资源大数据领域自 2010 年开始,以 Hadoop.Hive 为代表的离线计算开始进入各大公司的视野 ...

Flink 实时计算 - 进阶篇（如何自定义 Data Source 与 Data Sink）

第1关：Flink 实现自定义 Data Source (一)任务描述

Flink 实时计算 - 进阶篇（如何自定义 Data Source 与 Data Sink）相关推荐

最新文章

热门文章