當我應該使用流()在定義一個DLT表嗎?

[麥當娜]

你好,

我有點困惑當我應該使用流()當我們定義一個表基於DLT表。

有一個模式的解釋文檔。

創建或更新直播表streaming_bronze SELECT * FROM cloud_files (“s3: / /道路/ /生/數據”,“json”)創建或刷新流住表streaming_silver SELECT * FROM流(LIVE.streaming_bronze)…創建或刷新生活表live_gold住SELECT count (*)。streaming_silver GROUP BY user_id

在上麵的代碼中,“live_gold”是一種生活能力。自“streaming_silver”是一個直播表,我期望的最後一行代碼:

從流SELECT count (*) (LIVE.streaming_silver)由user_id集團

然而,流()不是用於“live_gold”的定義。

我想知道當我應該使用流()在定義一個生活表。

[LandanG]

嗨@Mohammad劍,

你使用流()在創建一個流媒體直播表和閱讀其他表的管道。關鍵的區別是直播表與表。

每個表的定義以及何時使用它們在文檔在這裏。

[麥當娜]

由於@Landan喬治

自“streaming_silver”是一個直播表,我期望的最後一行代碼:

從流SELECT count (*) (LIVE.streaming_silver)由user_id集團

但是,正如你可以看到“live_gold”被定義為:

從生活選擇count (*)。streaming_silver GROUP BY user_id

[LandanG · Accepted solution]

@Mohammad軍刀我想我明白你的意思。你隻需要包括流()函數聲明一個流媒體直播表時,不管數據的來源。

既然live_gold表隻是一個生活表,而不是現場直播表不需要包含這個函數。希望這是有意義的