Hi Garvit, Please refer to the Flink official documentation for the window description. [1] In this scenario, you should use Tumbling Windows. [2] If you want to call your own API to handle the window, you can extend the process window function to achieve your needs.[3]
[1]: https://ci.apache.org/projects/flink/flink-docs-master/dev/stream/operators/windows.html#windows [2]: https://ci.apache.org/projects/flink/flink-docs-master/dev/stream/operators/windows.html#tumbling-windows [3]: https://ci.apache.org/projects/flink/flink-docs-master/dev/stream/operators/windows.html#processwindowfunction Thanks, vino. Garvit Sharma <[email protected]> 于2018年8月13日周一 下午5:53写道： > Clarification: Its 30 Seconds not 30 minutes. > > On Mon, Aug 13, 2018 at 3:20 PM Garvit Sharma <[email protected]> wrote: > >> Hi, >> >> 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! >> >> Thanks, >> >> -- >> >> Garvit Sharma >> github.com/garvitlnmiit/ >> >> No Body is a Scholar by birth, its only hard work and strong >> determination that makes him master. >> > > > -- > > Garvit Sharma > github.com/garvitlnmiit/ > > No Body is a Scholar by birth, its only hard work and strong determination > that makes him master. >
