Monitoring streaming queries