Is this possible? Im wondering about gathering data from a stream into a series of windowed aggregators: minute, hour and day. A separate process would start at fixed intervals, query the appropriate state store for available values and then hopefully clear / zero / reset everything for the next interval.
I could use the retention period setting but I would (somehow) need to guarantee that the windows would reset on clock boundaries and not based on start time for the app.
