Hello,
We have problems working with states in Flink and I am sure you can help us :-) Let's say we have a workflow something like: DataStream<K> myData = env.from... myData.map(new MyMap (..)) .keyBy(0) .countWindow(n) .apply(new MyApplyFunction()) .writeAsCSV(...) To implement the logic of our MyApplyFunction, in the apply() method we would need to have access to the result of the last window computation. Before emiting the resulst in the apply () using collector.collect(..), we could save that result in an external storage systems (e.g Redis /Hazelcast) and then, in the begininig of the next window computation read such value, but we woud like to use some internal mechanism of Flink to do that. Could some provide help about it? Thanks in advance!!! :-) Best ______________________________________ Dr. Rubén Casado Head of Big Data Treelogic ruben.casado.treelogic +34 902 286 386 - +34 607 18 28 06 Parque Tecnológico de Asturias · Parcela 30 E33428 Llanera · Asturias [Spain] www.treelogic.com ______________________________________
