and I do not use a agg after window, I only use a process method after window and use a Java ArrayList to add each data in window.