flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From antonio saldivar <ansal...@gmail.com>
Subject Re: processWindowFunction
Date Fri, 17 Aug 2018 04:01:05 GMT
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 (<yanghua1127@gmail.com>)

> 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 <ansale10@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

View raw message