首页
学习
活动
专区
圈层
工具
发布

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

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

    基于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

    1.3K20

    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

    3.2K20

    Doris Catalog 已上线!性能提升 200x,全面优于 JDBC Catalog,跨集群查询迈入高性能分析时代

    在这一理念指引下,构建完善的Catalog生态是实现异构数据源统一查询分析的关键。...目前,Doris已支持Iceberg、Paimon、Hudi等数据湖Catalog,以及JDBCCatalog,用户无需迁移数据,即可对不同数据湖和传统数据库进行联邦查询分析。...展开代码语言:SQLAI代码解释SELECTcount(ss_item_sk),count(store_sales_amt),count(catalog_sales_amt)FROM(SELECTss.ss_item_skasss_item_sk...配置DorisCatalog在本地Doris集群执行以下SQL,创建连接远端物流集群的Catalog(虚拟集群模式):展开代码语言:SQLAI代码解释--创建DorisCatalog,启用虚拟集群模式(...远端集群登录密码'compatible'='false',--集群版本接近(4.0.3vs4.0.2),无需兼容'query_timeout_sec'='30'--延长查询超时时间(默认15秒));跨集群查询切换Catalog

    17310
    领券