Re: Flink keyed stream windows

Posted by vino yang on
URL: http://deprecated-apache-flink-user-mailing-list-archive.369.s1.nabble.com/Flink-keyed-stream-windows-tp22258p22265.html

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 <[hidden email]> 于2018年8月13日周一 下午5:53写道：

Clarification: Its 30 Seconds not 30 minutes.

On Mon, Aug 13, 2018 at 3:20 PM Garvit Sharma <[hidden email]> 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,

--

--