apex-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Chandni Singh (JIRA)" <j...@apache.org>
Subject [jira] [Commented] (APEXMALHAR-2276) ManagedState: value of a key does not get over-written in the same time bucket
Date Thu, 06 Oct 2016 15:40:20 GMT

    [ 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)

Mime
View raw message