Hi Amit,
the window function applied by default is
WindowingStrategy.globalDefault(), [1] - global window with zero allowed
lateness.
Cheers,
Jan
[1]
https://github.com/apache/beam/blob/master/sdks/java/core/src/main/java/org/apache/beam/sdk/values/WindowingStrategy.java#L105
On 3/31/20 10:22 AM, amit kumar wrote:
Hi All,
Is there a default WindowFn that gets applied to elements of an
unbounded source.
For example, if I have a Kinesis input source ,for which all elements
are timestamped with ArrivalTime, what will be the default windowing
applied to the output of read transform ?
Is this runner dependent ?
Regards,
Amit
