Add windowing support as the foundation of stream data processing. The components include window assigner, window state accumulator, window trigger etc.