David Yan created APEXMALHAR-2271: ------------------------------------- Summary: Special SpillableSetMultimap<K, Window.SessionWindow<K>> handling in ManagedState in SpillableSessionWindowedStorage Key: APEXMALHAR-2271 URL: https://issues.apache.org/jira/browse/APEXMALHAR-2271 Project: Apache Apex Malhar Issue Type: Sub-task Reporter: David Yan Assignee: David Yan
The problem with this data structure is that the key is not time based. This poses a problem because we will have a problem purging. One idea is to have `put` write the key and the window set to the timebucket that the latest window in that set belongs to, and make `get` do a for loop on all time buckets to find the key. That way, purging based on the time bucket can still be done. -- This message was sent by Atlassian JIRA (v6.3.4#6332)