會(huì)話窗口根據(jù)Session gap切分不同的窗口，當(dāng)一個(gè)窗口在大于Session gap的時(shí)間內(nèi)沒(méi)有接收到新數(shù)據(jù)時(shí)，窗口將關(guān)閉。

在這種模式下，窗口的長(zhǎng)度是可變的，每個(gè)窗口的開(kāi)始和結(jié)束時(shí)間并不是確定的。

我們可以設(shè)置定長(zhǎng)的Session gap，也可以使用SessionWindowTimeGapExtractor動(dòng)態(tài)地確定Session gap的長(zhǎng)度。

下面的代碼展示了如何使用定長(zhǎng)和可變的Session gap來(lái)建立會(huì)話窗口，其中SessionWindowTimeGapExtractor[T]的泛型T為數(shù)據(jù)流的類型，我們可以根據(jù)數(shù)據(jù)流中的元素來(lái)生成Session gap。