Hi Garvit,
One other point - once you start making HTTP requests, you likely want to use
an AsyncFunction to avoid the inefficiencies of your process spending most of
its time waiting for the remote server to handle the request.
Which means emitting the results (user + active location) from the
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
Clarification: Its 30 Seconds not 30 minutes.
On Mon, Aug 13, 2018 at 3:20 PM Garvit Sharma 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
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 strea
