expressive, composable stream analysis