请问Flink CDC这个以后可以支持为每个表设置分片的column吗?

目前，Flink CDC还没有直接支持为每个表设置分片的列的功能。不过，您可以采用一些变通的方式来实现类似的效果。
例如，您可以使用Flink CDC的分区功能来实现分片。您可以将表划分为若干分区，然后分别读取各个分区的数据。这样，每个分区就是一个分片。此外，您还可以使用Flink的并行度参数来控制并发读取的分区数量，以获得更高的性能。
另外，Flink CDC也支持自定义表结构和过滤条件，您可以结合这些功能来实现针对特定表的分片。
总之，虽然Flink CDC目前还不支持直接为每个表设置分片的列，但您可以通过一些变通的方式实现类似的效果。

Flink CDC确实支持为每个表设置分片的column，这在处理大数据量的场景中尤其重要。当数据量巨大时，例如达到亿级别，数据读取可能会耗费很长的时间。如果因为某些原因导致读取失败，就需要从头开始读取，这样会大大浪费时间，影响性能。通过分片机制，可以将大数据细分为小数据，提升效率。如果某个分片出现错误，还能在下次读取的时候续上，也就是我们所说的断点续传。同时，Flink CDC也支持数据的实时同步和表结构变更的自动同步。对于分库分表场景，每个表中必须包含MySQL CDC DDL中声明的字段。

可以的，合理需求，可以在GitHub上开个issue，此回答整理自钉群“Flink CDC 社区”

是的，FLINK CDC 支持设置分片的列以提高查询效率。但是请注意 FLINK CDC 不支持按特定分片列来进行 DELETE 操作。
要设置分片的列，请使用以下步骤：

1. 在建表语句中添加分片列的声明：

   CREATE TABLE my_table (
   id BIGINT,
   name STRING,
   age INT,
   SHARD BY (age)
   )
   

1. 在 Flink CDC 任务中指定分片列和相应索引：
   ```javascript
   options (
   sink.partition.column.name='age',
   sink.partition.index.name='my_index'
   )

COPY INTO my_table PARTITION(age)
FROM ...
```
这样您就可以将每个分片的数据分别写入到不同的分区。