When defining a TaskStore in GStreams, should be able to define an expiration policy (specifically for stores which contain data that uses a date in the key).
When the TaskStore is attached to a transformer, the transformer should have a punctuate defined (with a long interval, maybe 24h?) that iterates through the store and expunges expired records. On-the-fly expunging as well, if calling code calls .get() on a record that is expired, it should be removed from the store immediately and the calling code should receive Optional.empty(), or equivalent.
When defining a TaskStore in GStreams, should be able to define an expiration policy (specifically for stores which contain data that uses a date in the key).
When the TaskStore is attached to a transformer, the transformer should have a punctuate defined (with a long interval, maybe 24h?) that iterates through the store and expunges expired records. On-the-fly expunging as well, if calling code calls .get() on a record that is expired, it should be removed from the store immediately and the calling code should receive Optional.empty(), or equivalent.