K
- State key typeV
- State value type@PublicEvolving public class QueryableStateStream<K,V> extends Object
Constructor and Description |
---|
QueryableStateStream(String queryableStateName,
TypeSerializer<V> valueSerializer,
TypeSerializer<K> keySerializer)
Creates a queryable state stream.
|
Modifier and Type | Method and Description |
---|---|
TypeSerializer<K> |
getKeySerializer()
Returns the key serializer for the queryable state instance.
|
String |
getQueryableStateName()
Returns the name under which the state can be queried.
|
TypeSerializer<V> |
getValueSerializer()
Returns the value serializer for the queryable state instance.
|
public QueryableStateStream(String queryableStateName, TypeSerializer<V> valueSerializer, TypeSerializer<K> keySerializer)
queryableStateName
- Name under which to publish the queryable state instancevalueSerializer
- Value serializer for the state instancekeySerializer
- Key serializer for the state instancepublic String getQueryableStateName()
public TypeSerializer<V> getValueSerializer()
public TypeSerializer<K> getKeySerializer()
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.