Hi, sorry for the long wait but I finally found the time to read it. It looks good but the later parts of course still need to be fleshed out.
I have one comments/questions: In the description of partitioned state you have this sentence: "Operations using partitioned state can also benefit from the partial ordering guarantees that the flink runtime provides, to implement deterministic behaviour." How do we provide the ordering guarantees. I would assume that after a keyBy() the ordering in each partition is arbitrary, unless we add some sorting operator. Cheers, Aljoscha On Thu, 23 Jul 2015 at 15:55 Gyula Fóra <gyf...@apache.org> wrote: > Hey! > I started putting together a guide/design document for the streaming > operator state interfaces and implementations. The idea would be to create > a doc that contains all the details about the implementations so anyone can > use it as a reference later. > > > https://cwiki.apache.org/confluence/display/FLINK/Stateful+Stream+Processing > > It will probably take me a couple of days to finish it, but in any case > feel free to comment. > > Cheers, > Gyula >
