apex-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "bright chen (JIRA)" <j...@apache.org>
Subject [jira] [Commented] (APEXMALHAR-2193) Implement SpillableByteArrayListMultimapImpl.remove(@Nullable Object key, @Nullable Object value)
Date Mon, 22 Aug 2016 16:50:20 GMT

    [ https://issues.apache.org/jira/browse/APEXMALHAR-2193?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15431168#comment-15431168
] 

bright chen commented on APEXMALHAR-2193:
-----------------------------------------

All the update in fact only apply to in memory data. For the data already written to file(s),
only the most recent file take effect. When get the value of a key, first get value from memory,
then get value from files ordered by the time desc.

I had a solution for memory management, see PR https://github.com/apache/apex-malhar/pull/375
and  jira https://issues.apache.org/jira/browse/APEXMALHAR-2190. Right now, the reset() method
was called by client code( after AbstractManagedStateImpl.beforeCheckpoint(long) called),
it probably need to integrate with State management.

> Implement SpillableByteArrayListMultimapImpl.remove(@Nullable Object key, @Nullable Object
value)
> -------------------------------------------------------------------------------------------------
>
>                 Key: APEXMALHAR-2193
>                 URL: https://issues.apache.org/jira/browse/APEXMALHAR-2193
>             Project: Apache Apex Malhar
>          Issue Type: Sub-task
>            Reporter: David Yan
>            Assignee: David Yan
>
> This is needed by SpillableSessionWindowedStorage. It needs a way to remove the session
window given the key in its internal keyToWindowsMap



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)

Mime
View raw message