Flink CDC中oracle的WITH ();里面的参数是怎么写的吗?我这边写了一直报错。
Oracle CDC 的 WITH (); 里面的参数是 catalog, schema 和 table。
你可以使用以下语法指定这些参数:
WITH (
catalog = '',
schema = '',
table = ''
)
catalog 和 schema 必须是已经存在的,并且 table 必须是已经存在的或者已经创建的。
以下是一个使用 Oracle CDC WITH (); 参数的例子:
WITH (
catalog = 'my_catalog',
schema = 'my_schema',
table = 'my_table'
)
SELECT * FROM my_table;
这个语句将从 my_catalog.my_schema.my_table 表中读取数据。
版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。
实时计算Flink版是阿里云提供的全托管Serverless Flink云服务,基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎,提高作业开发运维效率。