首页
学习
活动
专区
工具
TVP
发布
精选内容/技术社群/优惠产品,尽在小程序
立即前往

Flink Catalog

Postgres Catalog 和 MySQL Catalog 是目前 JDBC Catalog 仅有的两种实现 HiveCatalog 作为原生 Flink 元数据的持久化存储,以及作为读写现有 Hive...元数据的接口 用户自定义 Catalog 用户可以通过实现 Catalog 接口来开发自定义 Catalog,除了需要实现自定义的 Catalog 之外,还需要为这个 Catalog 实现对应的 CatalogFactory...接口 设计 新的 Catalog 有三层结构,最顶层是 Catalog 的名字,中间一 层是 Database,最底层是各种 MetaObject,如 Table,Partition,Function...CatalogManager 支持的操作包括: 注册 Catalog(registerCatalog) 获取所有的 Catalog(getCatalogs) 获取特定的 Catalog(getCatalog...) 获取当前的 Catalog(getCurrentCatalog) 设置当前的 Catalog(setCurrentCatalog) 获取当前的 Database(getCurrentDatabase

73220
您找到你想要的搜索结果了吗?
是的
没有找到

基于catalog 的RMAN 备份与恢复

关于catalog的创建请参考:RMAN catalog的创建和使用 catalog方式的RMAN备份与恢复只不过是将备份恢复信息数据放在catalog目录内,普通的rman方式则是存放在控制文件中...catalog方式可以存储常用或特定的备份与恢复的脚本 有关catalog方式RMAN存储脚本请参考:基于 catalog 创建RMAN存储脚本 一、基于catalog来备份数据库(目标数据库orcl...,恢复目录数据库asmdb) 首先基于catalog创建备份脚本 --连接到RMAN [oracle@oradb ~]$ rman target sys/redhat@orcl catalog...; select * from tb2 * ERROR at line 1: ORA-01116: error in opening database file 4 ORA-01110: data...database datafile 2 online * ERROR at line 1: ORA-01116: error in opening database file 2 ORA-01110: data

91920

flink教程-详解flink 1.11 中的JDBC Catalog

提供了 JDBC catalog 的基础接口以及 Postgres catalog 的实现,这样方便后续实现与其它类型的关系型数据库的对接。...示例 目前对于jdbc catalog,flink仅提供了postgres catalog,我们基于postgres的catalog讲解一下如何使用flink的catalog , 引入pom    42.2.5          新建PostgresCatalog 目前flink通过一个静态类来创建相相应的jdbc  catalog...,'c')"); 完整的代码请参考: https://github.com/zhangjun0x01/bigdata-examples/blob/master/flink/src/main/java/catalog...,其他方式主要是对于Catalog的一些其他实现类做了特殊处理,比如类似create table 或者 alter table是不支持的,listView只是返回一个空列表,因为我们使用jdbc catalog

2.7K20
领券