取消
顯示的結果
而不是尋找
你的意思是:

Stream-stream窗口中加入時間窗後聚合不工作在13.1

azera
新的貢獻者二世

嘿,

我想表演時間窗口聚集在兩個不同的流緊隨其後加入stream-stream窗口描述在這裏。我跑步磚13.1運行時,具體的建議。

然而,當我複製下麵的代碼:

clicksWindow = clicksWithWatermark。groupBy (clicksWithWatermark。(clicksWithWatermark clickAdId,窗口。clickTime,“1小時”).count () impressionsWindow = impressionsWithWatermark。groupBy (impressionsWithWatermark。(impressionsWithWatermark impressionAdId,窗口。impressionTime,“1小時”).count clicksWindow ()。加入(impressionsWindow、“窗口”、“內部”)

我沒有得到任何結果從加入表附加模式。這隻是空無論我用去groupBy與否。同樣的行為是在Python和Scala。

如果我加入窗口。結束,而不是窗口,然後我開始接受結果但我隻可以使用內連接(加入條件,窗口。結束,不是有水印的列),但我需要做外連接我的用例(即使內連接,狀態似乎無限增加)。

任何幫助繁殖這個例子是感激

1回複1

Vidula_Khanna
主持人
主持人

嗨@Andrzej Zera

很高興認識你,謝謝你的問題!

看看你的同行在社區中有一個回答你的問題。謝謝。

歡迎來到磚社區:讓學習、網絡和一起慶祝

加入我們的快速增長的數據專業人員和專家的80 k +社區成員,準備發現,幫助和合作而做出有意義的聯係。

點擊在這裏注冊今天,加入!

參與令人興奮的技術討論,加入一個組與你的同事和滿足我們的成員。

Baidu
map