flink sql之数据源自定义扩展实现
上一篇咱们简单说了一下flink基于java spi建立自定义的数据源source和sink的基本原理，这一篇咱们结合实际案例具体说一下实现过程java
下面咱们先来看一下建立的时序图orm
从上图可知要实现自定义的source和sink，要实现以下几步blog
1.ExternalCatalog的自定义实现ip
2.ConnectorDescriptor的自定义实现kafka
3.引入flink kafka依赖form
4.schema format的自定义的实现(实现序列化和反序列)原理
具体实现代码还在整理中。。。。序列化
相关文章
- 1. 自定义扩展函数
- 2. Android-自定义meta-data扩展数据
- 3. Spark SQL自定义外部数据源
- 4. Mybatis Generator自定义扩展
- 5. rcp 自定义扩展点
- 6. Angular6+ webpack自定义扩展
- 7. Asp.Net Mvc 自定义扩展
- 8. 扩展和自定义liferay
- 9. ObjectiveSQL 扩展之—— 自定义Logger Framework
- 10. Beetlsql扩展之自定义Mapper
- 更多相关文章...
- • 自定义TypeHandler - MyBatis教程
- • Kotlin 扩展 - Kotlin 教程
- • Flink 数据传输及反压详解
- • RxJava操作符（十）自定义操作符
相关标签/搜索
每日一句
-
每一个你不满意的现在，都有一个你没有努力的曾经。
欢迎关注本站公众号,获取更多信息
