如何查询Flink 1.4.0中的可查询状态？

import org.apache.flink.api.common.functions.MapFunction;
import org.apache.flink.api.common.state.ValueState;
import org.apache.flink.api.common.state.ValueStateDescriptor;
import org.apache.flink.streaming.api.datastream.DataStream;
import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment;

public class QueryableStateExample {

    public static void main(String[] args) throws Exception {
        // 创建Flink执行环境
        StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();

        // 创建一个数据流
        DataStream<String> stream = env.socketTextStream("localhost", 9999);

        // 定义一个状态描述符
        ValueStateDescriptor<Integer> descriptor = new ValueStateDescriptor<>(
                "average", // 状态名称
                Integer.class // 状态类型
        );

        // 在数据流中查询状态
        DataStream<Integer> result = stream.map(new MapFunction<String, Integer>() {
            @Override
            public Integer map(String value) throws Exception {
                // 获取状态对象
                ValueState<Integer> state = getRuntimeContext().getState(descriptor);

                // 查询状态的值
                Integer currentValue = state.value();

                // 更新状态的值
                state.update(currentValue + 1);

                return currentValue;
            }
        });

        // 打印查询结果
        result.print();

        // 执行作业
        env.execute("Queryable State Example");
    }
}