在另一个管道中使用一个管道的DLT表



如果我有一个DLT管道,它创建了一个名为customers的流式实时表,我如何在另一个管道中使用该表?

所以,

  • 管道A:
CREATE OR REFRESH STREAMING LIVE TABLE customers AS 
  • 管道B:
CREATE OR REFRESH STREAMING LIVE TABLE sales AS
SELECT * FROM source a
INNER JOIN STREAM(LIVE.customers)

这不起作用,因为它表示无法访问客户数据集。

提前感谢您的帮助。

LIVE关键字只能用于同一管道(doc(内的引用。要引用另一个管道中的表,需要使用其全名database.name

对于生产使用,最好将表的名称定义为配置参数(因为数据库名称可能不同(,然后您应该能够使用${conf_name}语法引用它。

最新更新