google cloud dataflow - If I have applied a fixed window, will I always get an IntervalWindow from `window()` -
if implement dofn access window, sidecondition pcollection being transformed has had non-global windowing strategy applied it, i.e. fixedwidows guaranteed intervalwindow?
yes. window() method returns whatever kind of window current windowfn has placed element into. so, fixedwindows return intervalwindow.
it return single window. if you're using slidingwindows , each element placed 5 different windows, processelement() of dofn annotated requireswindowaccess called once each window element placed (so 5 times each element).
Comments
Post a Comment