osdir.com


[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index]

processWindowFunction


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