Hi Vino thank you for the information, actually I am using a trigger alert and processWindowFunction to send my results, but when my window slides or ends it sends again the objects and I an getting duplicated data
El jue., 16 ago. 2018 a las 22:05, vino yang (<yanghua1...@gmail.com>) escribió: > Hi Antonio, > > What results do not you want to get when creating each window? > Examples of the use of ProcessWindowFunction are included in many test > files in Flink's project, such as SideOutputITCase.scala or > WindowTranslationTest.scala. > > For more information on ProcessWindowFunction, you can refer to the > official website.[1] > > [1]: > https://ci.apache.org/projects/flink/flink-docs-release-1.6/dev/stream/operators/windows.html#processwindowfunction > > Thanks, vino. > > antonio saldivar <ansal...@gmail.com> 于2018年8月17日周五 上午6:24写道： > >> Hello >> >> I am implementing a data stream where I use sliding windows but I am >> stuck because I need to set values to my object based on some if statements >> in my process function and send the object to the next step but I don't >> want results every time a window is creating >> >> if anyone has a good example on this that can help me >> >
