本文整理了Java中org.apache.flink.streaming.api.datastream.KeyedStream.asQueryableState()方法的一些代码示例，展示了KeyedStream.asQueryableState()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。KeyedStream.asQueryableState()方法的具体详情如下：
包路径：org.apache.flink.streaming.api.datastream.KeyedStream
类名称：KeyedStream
方法名：asQueryableState

KeyedStream.asQueryableState介绍

[英]Publishes the keyed stream as queryable ValueState instance.
[中]将键控流发布为可查询的ValueState实例。

代码示例

代码示例来源：origin: apache/flink

/**
 * Publishes the keyed stream as queryable ValueState instance.
 *
 * @param queryableStateName Name under which to the publish the queryable state instance
 * @return Queryable state instance
 */
@PublicEvolving
public QueryableStateStream<KEY, T> asQueryableState(String queryableStateName) {
  ValueStateDescriptor<T> valueStateDescriptor = new ValueStateDescriptor<T>(
      UUID.randomUUID().toString(),
      getType());
  return asQueryableState(queryableStateName, valueStateDescriptor);
}

代码示例来源：origin: apache/flink

return value.f0;
}).asQueryableState("hakuna", valueState);

代码示例来源：origin: apache/flink

return value.f0;
}).asQueryableState(queryName, reducingState);

代码示例来源：origin: apache/flink

return value.f0;
}).asQueryableState("pumba", foldingState);

代码示例来源：origin: apache/flink

return value.f0;
}).asQueryableState(queryName, reducingState);
    return value.f0;
}).asQueryableState(queryName);

代码示例来源：origin: apache/flink

return 1;
}).asQueryableState("hakuna", valueState);

代码示例来源：origin: apache/flink

return value.f0;
}).asQueryableState("jungle", reducingState);

代码示例来源：origin: apache/flink

return value.f0;
}).asQueryableState("hakuna", valueState);

代码示例来源：origin: apache/flink

return value.f0;
}).asQueryableState("matata");

代码示例来源：origin: apache/flink

return value.f0;
}).asQueryableState("hakuna", valueState);

代码示例来源：origin: org.apache.flink/flink-streaming-java

/**
 * Publishes the keyed stream as queryable ValueState instance.
 *
 * @param queryableStateName Name under which to the publish the queryable state instance
 * @return Queryable state instance
 */
@PublicEvolving
public QueryableStateStream<KEY, T> asQueryableState(String queryableStateName) {
  ValueStateDescriptor<T> valueStateDescriptor = new ValueStateDescriptor<T>(
      UUID.randomUUID().toString(),
      getType());
  return asQueryableState(queryableStateName, valueStateDescriptor);
}

代码示例来源：origin: org.apache.flink/flink-streaming-java_2.10

/**
 * Publishes the keyed stream as queryable ValueState instance.
 *
 * @param queryableStateName Name under which to the publish the queryable state instance
 * @return Queryable state instance
 */
@PublicEvolving
public QueryableStateStream<KEY, T> asQueryableState(String queryableStateName) {
  ValueStateDescriptor<T> valueStateDescriptor = new ValueStateDescriptor<T>(
      UUID.randomUUID().toString(),
      getType());
  return asQueryableState(queryableStateName, valueStateDescriptor);
}

代码示例来源：origin: org.apache.flink/flink-streaming-java_2.11

/**
 * Publishes the keyed stream as queryable ValueState instance.
 *
 * @param queryableStateName Name under which to the publish the queryable state instance
 * @return Queryable state instance
 */
@PublicEvolving
public QueryableStateStream<KEY, T> asQueryableState(String queryableStateName) {
  ValueStateDescriptor<T> valueStateDescriptor = new ValueStateDescriptor<T>(
      UUID.randomUUID().toString(),
      getType());
  return asQueryableState(queryableStateName, valueStateDescriptor);
}