Hi, It's hard to tell without details about your algorithm, but what you're describing sounds to me like something you can use the workset for.
-V. On Feb 10, 2015 6:54 PM, "Alexander Alexandrov" < alexander.s.alexand...@gmail.com> wrote: > I am not sure whether this is supported at the moment. The only workaround > I could think of is indeed to use a boolean flag that indicates whether the > element has been deleted or not. > > An alternative approach is to ditch Flink's native iteration construct and > write your intermediate results to Tachyon or HDFS after each iteration > using the TypeInfoInput/OutputFormats. You then have full control how the > old and the new solutions sets should be merged. > > BTW can you share some details about that particular algorithm? I was > thinking about examples iterative algorithms with this property... > > Regards, > A. > > > 2015-02-10 14:18 GMT+01:00 Kruse, Sebastian <sebastian.kr...@hpi.de>: > >> Hi everyone, >> >> >> >> From playing around a bit around with delta iterations, I saw that you >> can update elements from the solution set and add new elements. My question >> is: is it possible to remove elements from the solution set (apart from >> marking them as “deleted” somehow)? >> >> >> >> My use case at hand for this is the following: In each iteration, I >> generate candidate solutions that I want to verify within the next >> iteration. If verification fails, I would like to remove them from the >> solution set, otherwise retain them. >> >> >> >> Thanks, >> >> Sebastian >> > >
