Flink CDC中mongocdc支不支持下游自动建表？

Flink CDC目前支持自动建表功能，可以读取MongodBCDC的数据并将其自动推送到目标表中。具体来说，您可以利用Flink CDC的Hive Sink或者JDBC Sink来实现自动建表的功能。
建议您可以参考以下示例代码：

    streamExecutionEnvironment.createInput(new FlinkKafkaConsumer<>(
        "topic",
        new RowSchemaConverter(schema),
        properties)
        .assignTimestampsAndWatermarks(new AscendingTimestampExtractor<MyType>() {
            @Override public long extractAscendingTimestamp(MyType element) {
                return element.getTimestamp();
            }
        })
        .setParallelism(parallelism));

注意：Hive Sink 和 JDBC Sink都支持自动建表功能，可以根据Mongodb CDC的数据自动创建目标表结构。

Flink CDC的MongoDB CDC连接器确实支持从MongoDB读取快照数据和增量数据。然而，对于动态建表（Dynamic Table）这一特性，目前的Flink CDC并未明确支持下游自动建表。在Flink中，Dynamic Table是支持流数据的Table API和SQL的核心概念，可以将表转换成一个变更流(changelog stream)，也可以回放变更流还原成一张表。但对于MongoDB CDC，它支持正则表达式过滤集合，用户可以在作业中指定所需监控的库名和集合名，可以用一个作业中监控多个数据库或多个集合。