DataLinkDC / dinky

Dinky is a real-time data development platform based on Apache Flink, enabling agile data development, deployment and operation.
http://www.dinky.org.cn
Apache License 2.0
3.18k stars 1.16k forks source link

[Feature][CDCSOURCE] Write to Starrocks auto create table #1773

Open dufeng1010 opened 1 year ago

dufeng1010 commented 1 year ago

Search before asking

Description

use flink sql to synchronize multi tables, when some tables not exists, it can auto create these tables.

Use case

No response

Related issues

No response

Are you willing to submit a PR?

Code of Conduct

aiwenmo commented 1 year ago

Can you provide suggestions on configuration information for ddl statements?

dufeng1010 commented 1 year ago

i want to add table model option(primary key, unique key, duplicate key, aggregate key)and bucket num option. base on primary key column for distributed by hash. for example. a table in mysql database create table test.mysql_test( id int primary key, name varchar(50), age int ).

auto create starrocks table for mysql_test in mysql database. create table test.mysql_test( id int, name string, age ) {table_model}(id) distributed by hash(id) buckets {buckets_num}

@aiwenmo can you help me to provide suggestions?

github-actions[bot] commented 10 months ago

Hello, this issue has not been active for more than 30 days. This issue will be closed in 7 days if there is no response. If you have any questions, you can comment and reply.

你好, 这个 issue 30 天内没有活跃,7 天后将关闭,如需回复,可以评论回复。