flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Chesnay Schepler (JIRA)" <j...@apache.org>
Subject [jira] [Updated] (FLINK-8525) How to query state in flink 1.4.0?
Date Tue, 30 Jan 2018 10:32:01 GMT

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

Chesnay Schepler updated FLINK-8525:
------------------------------------
    Component/s: Documentation

> How to query state in flink 1.4.0?
> ----------------------------------
>
>                 Key: FLINK-8525
>                 URL: https://issues.apache.org/jira/browse/FLINK-8525
>             Project: Flink
>          Issue Type: Test
>          Components: Documentation, 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
(v7.6.3#76005)

Mime
View raw message