public class GroupedAttributesFunction extends KeyedProcessFunction<String, TransactionAttribute, GroupedAttributes> {
    @Override
    public void processElement(
            TransactionAttribute txnAttr,
            Context ctx,
            Collector<GroupedAttributes> out) throws Exception {
...
        ctx.timerService().registerEventTimeTimer(ctx.timestamp() + Time.days(maxWindowForAllRules).toMilliseconds());
    }

    @Override
    public void onTimer(long timestamp, OnTimerContext ctx, Collector<GroupedAttributes> out) throws Exception {


// FIXME HELP I never enter this code!

        GroupedAttributes groupedAttributes = this.groupedAttributesValueState.value();
        if (groupedAttributes != null) {
            <http://log.info|log.info>("TODO clean out groupedAttribute state if older than 30 days");

        }
    }
}