Github user StefanRRichter commented on a diff in the pull request:
https://github.com/apache/flink/pull/5518#discussion_r169991617
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/state/KeyedStateBackend.java
---
@@ -61,8 +61,9 @@
* over it keys are not supported.
* @param state State variable for which existing keys will be returned.
* @param namespace Namespace for which existing keys will be returned.
+ * @param namespaceSerializer the serializer for the namespace.
*/
- <N> Stream<K> getKeys(String state, N namespace);
+ <N> Stream<K> getKeys(String state, N namespace, TypeSerializer<N>
namespaceSerializer);
--- End diff --
Currently, each registered state has its own column family, so that should
be ok. What made you think that this does not hold? (asking in case you found
something that should be fixed)
---
