如何将postgresCatalog重写为oracleCatalog?现在flinksql只支持postgres存储元数据,如果我想获得oracle元数据,如何重写postgresCatalog?
发布于 2021-12-16 08:30:48
将OracleCatalog添加到Flink有一个打开的票证,请参阅https://issues.apache.org/jira/browse/FLINK-17508
如果您想自己实现这一点,我建议您看看https://issues.apache.org/jira/browse/FLINK-16471和https://github.com/apache/flink/pull/11336,它们是最初的票证和引入PostgresCatalog到Flink的拉请求。您可以使用这些来确定OracleCatalog实现的样子。
https://stackoverflow.com/questions/70374826
复制相似问题