Re: Flink Stream assign unique transaction ID

2016-02-19 Thread Aljoscha Krettek
Hi, OperatorState was discarded in favor of ValueState, which you can retrieve using RuntimeContext.getState(…). This provides the same functionality as OperatorState but is the more future proof interface. Cheers, Aljoscha > On 19 Feb 2016, at 15:38, Tanguy Racinet wrote: > > Hi, > > I am cu

Flink Stream assign unique transaction ID

2016-02-19 Thread Tanguy Racinet
Hi, I am currently working on Flink streaming API and I am trying to assign unique IDs to transactions to track changes and mine Frequent Item Sets. I identified several potential solutions such as: - Check pointing Local variables (snapshotState and restoreState for once only passage) - Key