[FLINK-1080] [streaming] Streaming aggregation update and refactor