Flink 自定义 ClickHouse Table Connector 的简单实现

本次实现基于 Flink 1.18 版本，具体的对象之间的关系可以先参考官网的图： 先拿官网上的 Socket 示例来说一下实现过程： 首先编写 SocketDynamicTableFactory 实现 DynamicTableSourceFactory 接口。 在 SocketDynamicTab
posted @ 2024-03-19 21:41  小得盈满  阅读(66)  评论(0)  编辑  收藏  举报