Rest API calls

[yuvraj singh]

Hi I have a use case where I need to call rest apis from a flink . I am not getting much context form internet , please help me on this .

Thanks 

[vino yang]

Hi yuvraj,

The documentation of Flink REST API is here : https://ci.apache.org/projects/flink/flink-docs-release-1.5/monitoring/rest_api.html#monitoring-rest-api

Thanks, vino.

2018-08-01 3:29 GMT+08:00 yuvraj singh <[hidden email]>:

Hi I have a use case where I need to call rest apis from a flink . I am not getting much context form internet , please help me on this .

Thanks 

[yuvraj singh]

Hi vino , thanks for the information .

But I was looking for the use case where I need to call a web service on the stream .

Thanks 

Yubraj Singh 

On Wed, Aug 1, 2018, 8:32 AM vino yang <[hidden email]> wrote:

Hi yuvraj,

The documentation of Flink REST API is here : https://ci.apache.org/projects/flink/flink-docs-release-1.5/monitoring/rest_api.html#monitoring-rest-api

Thanks, vino.

2018-08-01 3:29 GMT+08:00 yuvraj singh <[hidden email]>:

Hi I have a use case where I need to call rest apis from a flink . I am not getting much context form internet , please help me on this .

Thanks 

[vino yang]

Hi yuvraj,

Sorry, I didn't see it clearly. I think in many UDF contexts, such as MapFunction, ProcessFunction, etc., you can access the Rest API as a client. 

Also if you want to improve performance, maybe async I/O will help you[1].

[1]: https://ci.apache.org/projects/flink/flink-docs-release-1.5/dev/stream/operators/asyncio.html

Thanks, vino.

2018-08-01 11:55 GMT+08:00 yuvraj singh <[hidden email]>:

Hi vino , thanks for the information .

But I was looking for the use case where I need to call a web service on the stream .

Thanks 

Yubraj Singh 

On Wed, Aug 1, 2018, 8:32 AM vino yang <[hidden email]> wrote:

Hi yuvraj,

The documentation of Flink REST API is here : https://ci.apache.org/projects/flink/flink-docs-release-1.5/monitoring/rest_api.html#monitoring-rest-api

Thanks, vino.

2018-08-01 3:29 GMT+08:00 yuvraj singh <[hidden email]>:

Hi I have a use case where I need to call rest apis from a flink . I am not getting much context form internet , please help me on this .

Thanks 

[Rong Rong]

Hi Yuvraj,

Vino is right, having a customized function is probably the easiest at this moment. 

Alternatively, I think what you are looking for is very much similar to side-input feature of data stream[2]. 

Thanks,

Rong

[2] FLIP-17: https://cwiki.apache.org/confluence/display/FLINK/FLIP-17+Side+Inputs+for+DataStream+API

On Wed, Aug 1, 2018 at 5:10 AM vino yang <[hidden email]> wrote:

Hi yuvraj,

Sorry, I didn't see it clearly. I think in many UDF contexts, such as MapFunction, ProcessFunction, etc., you can access the Rest API as a client. 

Also if you want to improve performance, maybe async I/O will help you[1].

[1]: https://ci.apache.org/projects/flink/flink-docs-release-1.5/dev/stream/operators/asyncio.html

Thanks, vino.

2018-08-01 11:55 GMT+08:00 yuvraj singh <[hidden email]>:

Hi vino , thanks for the information .

But I was looking for the use case where I need to call a web service on the stream .

Thanks 

Yubraj Singh 

On Wed, Aug 1, 2018, 8:32 AM vino yang <[hidden email]> wrote:

Hi yuvraj,

The documentation of Flink REST API is here : https://ci.apache.org/projects/flink/flink-docs-release-1.5/monitoring/rest_api.html#monitoring-rest-api

Thanks, vino.

2018-08-01 3:29 GMT+08:00 yuvraj singh <[hidden email]>:

Hi I have a use case where I need to call rest apis from a flink . I am not getting much context form internet , please help me on this .

Thanks