嘿,
我想表演時間窗口聚集在兩個不同的流緊隨其後加入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。
如果我加入窗口。結束,而不是窗口,然後我開始接受結果但我隻可以使用內連接(加入條件,窗口。結束,不是有水印的列),但我需要做外連接我的用例(即使內連接,狀態似乎無限增加)。
任何幫助繁殖這個例子是感激
