Hi Ravikumar, Flink's operators are stateful. So you can simply create a variable in your mapper to keep the state around. But every mapper instance will have it's own state. This state is determined by the records which are sent to this mapper instance. If you need a global state, then you have to set the parallelism to 1.
Cheers, Till On Wed, Jun 8, 2016 at 5:08 PM, Ravikumar Hawaldar < ravikumar.hawal...@gmail.com> wrote: > Hello, > > I have an DataSet<UserDefinedType> which is roughly a record in a DataSet > Or a file. > > Now I am using map transformation on this DataSet to compute a variable > (coefficients of linear regression parameters and data structure used is a > double[]). > > Now the issue is that, per record the variable will get updated and I am > struggling to maintain state of this variable for the next record. > > In simple, for first record the variable values will be 0.0, and after > first record the variable will get updated and I have to pass this updated > variable for the second record and so on for all records in DataSet. > > Any suggestions on how to maintain state of a variable? > > > Regards, > Ravikumar >
