On Thu, Jan 20, 2022 at 2:46 AM yidan zhao wrote:
> self-define the window assigners.
>
Thanks, I'll check that out. If you have links to especially good examples
and explanations, that would be great. Otherwise, I presume the Flink
codebase itself is the place to start.
--
Cheers,
Aeden
session-windows
>
> Aeden Jameson 于2022年1月15日周六 02:16写道:
>
>> When using tumbling windows the windows materialize all at once which
>> results in burst-y traffic. How does one go about unaligned tumbling
>> windows? Does this require going down the road of custom window
1]. Does that meet
> your needs?
>
> [1]
> https://nightlies.apache.org/flink/flink-docs-master/docs/dev/datastream/operators/windows/#session-windows
>
> Aeden Jameson 于2022年1月15日周六 02:16写道:
>
>> When using tumbling windows the windows materialize all at once which
>> resu
session-windows
Aeden Jameson 于2022年1月15日周六 02:16写道:
> When using tumbling windows the windows materialize all at once which
> results in burst-y traffic. How does one go about unaligned tumbling
> windows? Does this require going down the road of custom window, assigner
> and triggers?
>
> --
> Cheers,
> Aeden
>
>
>
When using tumbling windows the windows materialize all at once which
results in burst-y traffic. How does one go about unaligned tumbling
windows? Does this require going down the road of custom window, assigner
and triggers?
--
Cheers,
Aeden