jia liu created FLINK-8525:
------------------------------
Summary: 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: Queryable State
Affects Versions: 1.4.0
Reporter: jia liu
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)
