flink-table-api相关内容
为了丰富数据流,我们计划将MySQL(MemSQL)服务器连接到现有的Flink流应用程序 我们可以看到,Flink提供了一个带有JDBC连接器的表APIhttps://nightlies.apache.org/flink/flink-docs-master/docs/connectors/table/jdbc/ 此外,我还发现了另一个名为Flink-CDChttps://verver
..
这感觉很明显,但我还是问一下,因为我在文档中找不到明确的确认: Flink 1.12 中可用的 Flink Table API upsert kafka 连接器 与 Kafka 压缩主题的语义非常匹配:将流解释为变更日志并使用 NULL 值作为墓碑来标记删除. 所以我的假设是可以使用它来消费和生产压缩主题,并且它可能正是为此而制作的,尽管它应该可以很好地与非-压缩主题假设其内容确实是一
..
这感觉很明显,但我还是问一下,因为我在文档中找不到明确的确认: Flink 1.12 中可用的 Flink Table API upsert kafka 连接器 与 Kafka 压缩主题的语义非常匹配:将流解释为变更日志并使用 NULL 值作为墓碑来标记删除. 所以我的假设是可以使用它来消费和生产压缩主题,并且它可能正是为此而制作的,尽管它应该可以很好地与非-压缩主题假设其内容确实是一
..