先上链接, Versioned Table
<https://nightlies.apache.org/flink/flink-docs-release-1.15/docs/dev/table/concepts/versioned_tables/>
从文档描述中可知,以Upsert-Kafka作为Source,以debezium或canal作为format时,可被认为是Versioned
Table Source。

1. 那么flink cdc所提供的connector下,是否也可以被认定为一种Versioned Table Source?
2. Versioned Table 在转化成DataStream时,转化后是否必定是一个restract stream?
3. 是否所有的Versioned Table,都可以发送往带有撤销能力的sink(如MySQL/ES/Hudi等等)?

回复