You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/01/30 10:32:01 UTC
[jira] [Updated] (FLINK-8525) How to query state in flink 1.4.0?
[ 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)