Flink and Rest API

[Alberto Ramón]

* 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)

[Hung]

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/

[Till Rohrmann]

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 <[hidden email]> 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/

[Alberto Ramón]

Thanks Till and Sendoh

On 5 January 2018 at 12:38, Till Rohrmann <[hidden email]> 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 <[hidden email]> 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/