Arun Mahadevan commented on STORM-1961:

Hi [~jerrypeng] right now the updateStateByKey operation is built on top of 
StatefulBolt abstraction that can save state externally. The other operations 
maintain state in memory and rely on storms acking/replay mechanisms and so it 
can provide only at-least once guarantees. I had some initial thoughts on how 
we could improve this in future to provide a notion of exactly once. I will 
update the design docs with more details soon.

> Come up with streams api for storm core use cases
> -------------------------------------------------
>                 Key: STORM-1961
>                 URL: https://issues.apache.org/jira/browse/STORM-1961
>             Project: Apache Storm
>          Issue Type: Sub-task
>            Reporter: Arun Mahadevan
>            Assignee: Arun Mahadevan
>         Attachments: UnifiedStreamapiforStorm.pdf

This message was sent by Atlassian JIRA

Reply via email to