You are viewing a plain text version of this content. The canonical link for it is here.

Posted to user@flink.apache.org by Alberto Ramón <a....@gmail.com> on 2018/01/04 19:50:58 UTC

Flink and Rest API

* Read from Rest API in streaming / micro batch some values ( Example: read
last Value of BitCoin)

*  Expose Queriable State as as queriable Rest API (Example: Expose
intermediate results on demmand)

Re: Flink and Rest API

Posted by Alberto Ramón <a....@gmail.com>.

Thanks Till and Sendoh

On 5 January 2018 at 12:38, Till Rohrmann <tr...@apache.org> wrote:

> Hi Alberto,
>
> currently, the queryable state is not exposed via a REST interface. You
> have to use the QueryableStateClient for that [1]. If it's not possible to
> directly connect to the machines running your Flink cluster, then you can
> also expose the values via the metric system as Sendoh proposed.
>
> [1] https://ci.apache.org/projects/flink/flink-docs-
> release-1.4/dev/stream/state/queryable_state.html#example
>
> Cheers,
> Till
>
> On Fri, Jan 5, 2018 at 9:44 AM, Sendoh <un...@gmail.com> wrote:
>
>> I think the first requirement is possible by using accumulator or metric,
>> or?
>>
>> Cheers,
>>
>> Sendoh
>>
>>
>>
>> --
>> Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.
>> nabble.com/
>>
>
>

Re: Flink and Rest API

Posted by Till Rohrmann <tr...@apache.org>.

Hi Alberto,

currently, the queryable state is not exposed via a REST interface. You
have to use the QueryableStateClient for that [1]. If it's not possible to
directly connect to the machines running your Flink cluster, then you can
also expose the values via the metric system as Sendoh proposed.

[1]
https://ci.apache.org/projects/flink/flink-docs-release-1.4/dev/stream/state/queryable_state.html#example

Cheers,
Till

On Fri, Jan 5, 2018 at 9:44 AM, Sendoh <un...@gmail.com> wrote:

> I think the first requirement is possible by using accumulator or metric,
> or?
>
> Cheers,
>
> Sendoh
>
>
>
> --
> Sent from: http://apache-flink-user-mailing-list-archive.2336050.
> n4.nabble.com/
>

Re: Flink and Rest API

Posted by Sendoh <un...@gmail.com>.

I think the first requirement is possible by using accumulator or metric, or?

Cheers,

Sendoh



--
Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/