What you can do is creating an initial control stream e.g. using
`StreamExecutionEnivronment.fromElements()` and either use
`union(controlStream, actualStream)` or use
`actualStream.connect(controlStream)`.
Regards,
Timo
On 12.08.20 18:15, Andrey Zagrebin wrote:
I do not think so. Each timer in KeyedProcessFunction is associated with
the key. The key is implicitly set into the context from the record
which is currently being processed.
On Wed, Aug 12, 2020 at 8:00 AM Marco Villalobos
<mvillalo...@kineteque.com <mailto:mvillalo...@kineteque.com>> wrote:
In the Stream API KeyedProcessFunction,is there a way to start a
timer without ever receiving a stream event?
