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

[dufeng1010]

Search before asking

• [X] I had searched in the issues and found no similar feature requirement.

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?

• [x] Yes I am willing to submit a PR!

Code of Conduct

• [X] I agree to follow this project's Code of Conduct

[aiwenmo]

Can you provide suggestions on configuration information for ddl statements?

[dufeng1010]

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]]

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 天后将关闭，如需回复，可以评论回复。