开发者社区

文档建议反馈控制台

最新优惠活动

文章/答案/技术大牛

发布

社区首页 >专栏 >flink sql之数据源自定义扩展实现

flink sql之数据源自定义扩展实现

yiduwangkai

发布于 2019-09-17 16:02:53

1.1K0

发布于 2019-09-17 16:02:53

举报

文章被收录于专栏：大数据进阶

上一篇我们简单说了一下flink基于java spi创建自定义的数据源source和sink的基本原理，这一篇我们结合实际案例具体说一下实现过程

下面我们先来看一下创建的时序图

从上图可知要实现自定义的source和sink，要实现如下几步

1.ExternalCatalog的自定义实现

2.ConnectorDescriptor的自定义实现

3.引入flink kafka依赖

4.schema format的自定义的实现(实现序列化和反序列)

具体实现代码还在整理中。。。。

本文参与腾讯云自媒体同步曝光计划，分享自作者个人站点/博客。

如有侵权请联系 cloudcommunity@tencent.com 删除

本文分享自作者个人站点/博客前往查看

如有侵权，请联系 cloudcommunity@tencent.com 删除。

本文参与腾讯云自媒体同步曝光计划，欢迎热爱写作的你一起参与！

评论

登录后参与评论

0 条评论

热度

最新

LV.

相关产品与服务

大数据

全栈大数据产品，面向海量数据场景，帮助您 “智理无数，心中有数”！

精选特惠用云无忧