[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index]

Flink keyed stream windows


I am working on a use case where I have a stream of users active locations and I want to store(by hitting an HTTP API) the latest active location for each of the unique users every 30 minutes.

Since I have a lot of unique users(rpm 1.5 million), how to use Flink's timed windows on keyed stream to solve this problem.

Please help!



Garvit Sharma

No Body is a Scholar by birth, its only hard work and strong determination that makes him master.