描述
- 對一個窗口中的同個key的所有數(shù)據進行批量處理
- context.window提供了對窗口屬性的訪問谋减，如context.window.getStart訪問窗口的左開區(qū)間琐脏，context.window.getEnd訪問窗口的右閉區(qū)間
- context提供了對時間屬性的訪問
- context提供了對狀態(tài)的訪問
- context提供了側流輸出
- 使用out對象進行主流輸出
用法
class MyProcessWindowFunc extends ProcessWindowFunction[輸入類型, 輸出類型, Key類型, 窗口類型(分為TimeWindow首繁、GlobalWindow践宴、Window三類)] {
override def process(key: Key類型, context: Context, elements: Iterable[輸入類型], out: Collector[輸出類型]): Unit = {
// key：數(shù)據的Key
// context：上下文環(huán)境對象
// elements：一個窗口中同個key的所有數(shù)據
// out：提供主流輸出的對象
...
}
}
