modify solution set within the delta iteration

classic Classic list List threaded Threaded
2 messages Options
Reply | Threaded
Open this post in threaded view
|

modify solution set within the delta iteration

Riccardo Diomedi
I try to explain my situation

I’m doing a delta iteration in which my solution set in something like:
DataSet<Tuple3<key, value, HashMap>>

Depending on a different dataset that i retrieve during the iteration, i need to update the hashMap of the solution set in order to keep it up to date.

But i noticed that i cannot modify the solution set within the iteration, so i was wondering if there is a way to do that?

thanks

Riccardo
Reply | Threaded
Open this post in threaded view
|

Re: modify solution set within the delta iteration

rmetzger0
Hi Riccardo,

I don't think you can use delta iterations when your solution set changes over time.
For those cases, I would use the bulk iterations in Flink.

On Mon, Mar 21, 2016 at 12:26 PM, Riccardo Diomedi <[hidden email]> wrote:
I try to explain my situation

I’m doing a delta iteration in which my solution set in something like:
DataSet<Tuple3<key, value, HashMap>>

Depending on a different dataset that i retrieve during the iteration, i need to update the hashMap of the solution set in order to keep it up to date.

But i noticed that i cannot modify the solution set within the iteration, so i was wondering if there is a way to do that?

thanks

Riccardo