ed
> with another stream for defined window size such as
> Time.milliseconds(10000). How can I change window size during runtime to
> Time.milliseconds(2)?
>
>
> Stream1.join(Stream2)
> .where(new SingleValueSensorKeySelector())
>
You can't change the window size at runtime.
On 03.01.2019 00:54, Rad Rad wrote:
Hi All,
I have one stream is consumed by FlinkKafkaConsumer which will be joined
with another stream for defined window size such as
Time.milliseconds(1). How can I change window size during runti
Hi All,
I have one stream is consumed by FlinkKafkaConsumer which will be joined
with another stream for defined window size such as
Time.milliseconds(1). How can I change window size during runtime to
Time.milliseconds(2)?
Stream1.join(Stream2)
.where
