[jira] [Closed] (FLINK-8525) Improve queryable state code examples

["Till Rohrmann (Jira)" <ji...@apache.org>]

     [ https://issues.apache.org/jira/browse/FLINK-8525?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Till Rohrmann closed FLINK-8525.
--------------------------------
    Resolution: Abandoned

Closing for inactivity.

> Improve queryable state code examples
> -------------------------------------
>
>                 Key: FLINK-8525
>                 URL: https://issues.apache.org/jira/browse/FLINK-8525
>             Project: Flink
>          Issue Type: Improvement
>          Components: Documentation, Runtime / Queryable State
>    Affects Versions: 1.4.0
>            Reporter: jia liu
>            Priority: Minor
>
> I't really very hard to understand the code in documents.
> {code:java}
> QueryableStateClient client = new QueryableStateClient(tmHostname, proxyPort);
> // the state descriptor of the state to be fetched.
> ValueStateDescriptor<Tuple2<Long, Long>> descriptor =
>         new ValueStateDescriptor<>(
>           "average",
>           TypeInformation.of(new TypeHint<Tuple2<Long, Long>>() {}),
>           Tuple2.of(0L, 0L));
> CompletableFuture<ValueState<Tuple2<Long, Long>>> resultFuture =
>         client.getKvState(jobId, "query-name", key, BasicTypeInfo.LONG_TYPE_INFO, descriptor);
> // now handle the returned value
> resultFuture.thenAccept(response -> {
>         try {
>             Tuple2<Long, Long> res = response.get();
>         } catch (Exception e) {
>             e.printStackTrace();
>         }
> });
> {code}
> I can't get the declaration of key and jobId from it. And the most important, there is no test case in flink-queryable-state module.



--
This message was sent by Atlassian Jira
(v8.3.4#803005)