[
https://issues.apache.org/jira/browse/FLINK-8525?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-8525:
------------------------------------
Issue Type: Improvement (was: Test)
> 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: Improvement
> 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)
