[Spain]
www.treelogic.com
__
- Mensaje original -
De: "Aljoscha Krettek"
Para: user@flink.apache.org
Enviados: Jueves, 21 de Abril 2016 11:21:00 GMT +01:00 Amsterdam / Berlín /
Berna / Roma / Estocolmo / Viena
Asunto: Re: save state
Hi,
you should be able to do this using Flink's state abstraction in a
RichWindowFunction like this:
public static class MyApplyFunction extends
RichWindowFunction, Tuple2, Tuple,
GlobalWindow> {
ValueStateDescriptor> stateDescriptor =
new ValueStateDescriptor<>("last-result",
