[
https://issues.apache.org/jira/browse/APEXMALHAR-2276?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15552263#comment-15552263
]
Chandni Singh commented on APEXMALHAR-2276:
-------------------------------------------
This needs to be handled by the client (client of ManagedTimeStateImpl).
The client needs to perform a get() and then a put().
The methods get(bucketId, time, Slice key) are documented in
TimeSlicedBucketedState interface and it is mentioned that it first tries to
search for a key in the cache than on the filesystem.
ManagedState is basically for handling checkpointing of large state. The time
in ManagedState is basically used to save data on filesystem in time-buckets
which can be purged effectively.
> ManagedState: value of a key does not get over-written in the same time bucket
> ------------------------------------------------------------------------------
>
> Key: APEXMALHAR-2276
> URL: https://issues.apache.org/jira/browse/APEXMALHAR-2276
> Project: Apache Apex Malhar
> Issue Type: Bug
> Reporter: Siyuan Hua
> Assignee: Chandni Singh
> Fix For: 3.6.0
>
>
> For example:
> ManagedTimeUnifiedStateImpl mtus;
> mtus.put(10000, key1, val1)
> mtus.put(10000, key1, val2)
> mtus.get(10000, key1).equals(val2) will return false
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
