[FLINK-22052][python] Add new state backends to PyFlink

apache · Mar 31, 2021 · 96aa09c · 96aa09c
1 parent 0c7ab0b
commit 96aa09c
Show file tree

Hide file tree

Showing 4 changed files with 405 additions and 19 deletions.
diff --git a/flink-python/pyflink/datastream/__init__.py b/flink-python/pyflink/datastream/__init__.py
@@ -99,6 +99,8 @@
     'SourceFunction',
     'StateBackend',
     'MapFunction',
+    'HashMapStateBackend',
+    'EmbeddedRocksDBStateBackend',
     'MemoryStateBackend',
     'FsStateBackend',
     'RocksDBStateBackend',