我尝试每月聚合数据（使用tumblingeventtimewindows），但我希望每天更新输出。
1） 自定义触发器是解决此问题的最佳方案吗？
2） 如何在scala中准备这样一个触发器？