案例：自定義一個(gè)源，每隔隨機(jī)的秒(1~10)之間產(chǎn)生1條數(shù)據(jù)

數(shù)據(jù)是key value，key：hadoop Spark flink 其中一個(gè)，value：是隨機(jī)的數(shù)字

需求1：定義一個(gè)會(huì)話時(shí)間窗口、5秒間隙、統(tǒng)計(jì)全量數(shù)據(jù)之和

需求2：定義一個(gè)會(huì)話時(shí)間窗口，5秒間隙，統(tǒng)計(jì)按照key分組后的每組數(shù)據(jù)內(nèi)的數(shù)字和

注意：會(huì)話時(shí)間窗口必須打包，不打包的話沒(méi)有自帶的實(shí)現(xiàn)方法，需要手動(dòng)實(shí)現(xiàn)窗口自行實(shí)現(xiàn)