Grand challenge: implementation by frequently emitting parallel windows and user-defined aggregate functions.