flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "G.S.Vijay Raajaa" <gsvijayraa...@gmail.com>
Subject REST API call in stream transformation
Date Thu, 27 Apr 2017 09:28:39 GMT

I have just started to explore Flink and have couple of questions. I  am
wondering if its possible to call a rest endpoint asynchronously and pipe
the response to the next state of my transformation on the stream. The idea
is such that after charging my data in a predefined time window, I would
like to apply some algorithm/transformation on the window of data external
to Flink. The algos have been exposed as REST endpoints.

My seconds question is an extension to the previous one, if i need to
transform my window data by applying three different algorithms in parallel
exposed via subsequent rest endpoints, how do wait unless the individual
rest endpoints respond back . Potentially I need to join the results of the
three algorithms before I call the sink.

Vijay Raajaa

View raw message