更新时间:2024-09-02 GMT+08:00

数据共享函数

pgxc_group_add_subscription(src_vw_name, target_vw_name)

描述:存算分离架构下,逻辑集群(Virtual Warehouse,以下简称VW)之间建立KV订阅关系,建立了订阅关系之后,消费者VW的KVcahce会定期的从生产者的obs cudesc快照目录增量同步sst文件到本地,后续就可以支持在消费者VM中跨VW查询生产者VW中的表。 创建的订阅关系可以在pgxc_group_subscription表中查询到记录。该函数仅9.0.3及以上集群版本支持。

返回值类型:void

返回信息如下:

表1 pgxc_group_add_subscription(src_vw_name, target_vw_name)返回字段

名称

类型

描述

src_vw_name

text

生产者VW名称,通常作为写入数据的VW。

target_vw_name

text

消费者VW名称,通常作为读取数据的VW。

示例:

1
2
3
4
5
SELECT pgxc_group_add_subscription('write_group', 'single_read_group');
pgxc_group_add_subscription 
------------------

(1 row)

pgxc_group_drop_subscription(src_vw_name, target_vw_name)

描述:存算分离架构下,删除VW之间已经建立的KV订阅关系,删除操作是删除pgxc_group_subscription表的记录, 删除KV订阅关系后,消费者VW无法继续跨VW查询生产者VW中的表。该函数仅9.0.3及以上集群版本支持。

返回值类型:void

返回信息如下:

表2 pgxc_group_drop_subscription(src_vw_name, target_vw_name)返回字段

名称

类型

描述

src_vw_name

text

生产者VW名称,通常作为写入数据的VW。

target_vw_name

text

消费者VW名称,通常作为读取数据的VW。

示例:

SELECT  pgxc_group_drop_subscription('write_group', 'single_read_group');
pgxc_group_drop_subscription 
------------------------------
(1 row)