Class QueryableStateStream<K,V>
- java.lang.Object
-
- org.apache.flink.streaming.api.datastream.QueryableStateStream<K,V>
-
- Type Parameters:
K
- State key typeV
- State value type
@PublicEvolving @Deprecated public class QueryableStateStream<K,V> extends Object
Deprecated.The Queryable State feature is deprecated since Flink 1.18, and will be removed in a future Flink major version.Queryable state stream instance.
-
-
Constructor Summary
Constructors Constructor Description QueryableStateStream(String queryableStateName, StateDescriptor<?,V> stateDescriptor, TypeSerializer<K> keySerializer)
Deprecated.Creates a queryable state stream.
-
Method Summary
All Methods Instance Methods Concrete Methods Deprecated Methods Modifier and Type Method Description TypeSerializer<K>
getKeySerializer()
Deprecated.Returns the key serializer for the queryable state instance.String
getQueryableStateName()
Deprecated.Returns the name under which the state can be queried.StateDescriptor<?,V>
getStateDescriptor()
Deprecated.Returns the state descriptor for the queryable state instance.
-
-
-
Constructor Detail
-
QueryableStateStream
public QueryableStateStream(String queryableStateName, StateDescriptor<?,V> stateDescriptor, TypeSerializer<K> keySerializer)
Deprecated.Creates a queryable state stream.- Parameters:
queryableStateName
- Name under which to publish the queryable state instancestateDescriptor
- The state descriptor for the state instancekeySerializer
- Key serializer for the state instance
-
-
Method Detail
-
getQueryableStateName
public String getQueryableStateName()
Deprecated.Returns the name under which the state can be queried.- Returns:
- Name under which state can be queried.
-
getKeySerializer
public TypeSerializer<K> getKeySerializer()
Deprecated.Returns the key serializer for the queryable state instance.- Returns:
- Key serializer for the state instance.
-
getStateDescriptor
public StateDescriptor<?,V> getStateDescriptor()
Deprecated.Returns the state descriptor for the queryable state instance.- Returns:
- State descriptor for the state instance
-
-