- 修改或增加 ClickHouse Sink 表的 DDL SQL 和 DML SQL，参考 clickhouse_dml_1.sql 和 clickhouse_sink_1.sql
- 修改或增加 source 数据里的表名字段与 ClickHouse Sink 相关 SQL 的映射关系
- 可能的增加 UDTF
- ClickHouse Connector 的使用参考 数据仓库 ClickHouse，本地开发时需要的 JAR 包联系 Oceanus 获取
-
Notifications
You must be signed in to change notification settings - Fork 0
lzshlzsh/flink-kafka-to-clickhouse
Folders and files
| Name | Name | Last commit message | Last commit date | |
|---|---|---|---|---|
Repository files navigation
About
No description, website, or topics provided.
Resources
Stars
Watchers
Forks
Releases
No releases published
Packages 0
No packages published