[jira] [Created] (FLINK-8525) How to query state in flink 1.4.0?

["jia liu (JIRA)" <ji...@apache.org>]

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)