我正在使用Flink流以替换我的ETL流。我正在处理的任务之一是-计算不同的每日活跃用户。任务本身并不难实施。问题是我需要每小时更新一次有关当前计数的仪表板。
如果创建一个一小时的窗口，我将仅获得一个小时的非重复计数，但是如果用户回到不同的小时，我将对其计数两次。
有人有想法吗？
谢谢！
嗯...您可以将当天的时间戳用作功能键吗？如果可以执行此操作，则可以通过丰富功能来管理少量用户以进行检查。当一天结束时，此计数将自动重置。