??????v1.10.1
????AggregateFunction+ProcessWindowFunction??????????????????????ProcessWindowFunction??????????????????????????????????????????+????????????????????????????????????????????????????????????????????????????????ProcessWindowFunction??clear??????????????????????????????23??59??00??????????override
def clear(ctx: Context): Unit = {
val dt = new SimpleDateFormat("HH:mm:00").format(ctx.window.getStart)
if(dt.equals("23:59:00")){
state.clear()??????????????????????????keyBy????????????key????????????????????????????????????????????????????????????????????????????????????????????????????????????????????????????????????????????????????????????????????????????
