This is an automated email from the ASF dual-hosted git repository.
dianfu pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
The following commit(s) were added to refs/heads/master by this push:
new 0009b0c [hotfix][python][docs] Add state API in PyDocs
0009b0c is described below
commit 0009b0cfec35dc88116ed41dde6a4c9a17f2ea09
Author: Dian Fu <dia...@apache.org>
AuthorDate: Thu Aug 26 11:07:39 2021 +0800
[hotfix][python][docs] Add state API in PyDocs
---
flink-python/docs/pyflink.datastream.rst | 6 ++++++
flink-python/pyflink/datastream/__init__.py | 3 ---
2 files changed, 6 insertions(+), 3 deletions(-)
diff --git a/flink-python/docs/pyflink.datastream.rst
b/flink-python/docs/pyflink.datastream.rst
index 8674b97..ee5126e 100644
--- a/flink-python/docs/pyflink.datastream.rst
+++ b/flink-python/docs/pyflink.datastream.rst
@@ -27,6 +27,12 @@ Module contents
:undoc-members:
:show-inheritance:
+pyflink.datastream.state module
+------------------------------------
+.. automodule:: pyflink.datastream.state
+ :members:
+ :undoc-members:
+
pyflink.datastream.connectors module
------------------------------------
.. automodule:: pyflink.datastream.connectors
diff --git a/flink-python/pyflink/datastream/__init__.py
b/flink-python/pyflink/datastream/__init__.py
index 5b75dbc..1528d2b 100644
--- a/flink-python/pyflink/datastream/__init__.py
+++ b/flink-python/pyflink/datastream/__init__.py
@@ -63,9 +63,6 @@ Functions used to transform a :class:`DataStream` into
another :class:`DataStrea
- :class:`KeyedCoProcessFunction`:
Similar to :class:`CoProcessFunction`, except that it was applied to a
keyed
:class:`ConnectedStreams` and could register event-time and
processing-time timers.
- - :class:`KeyedCoProcessFunction`:
- Similar to :class:`CoProcessFunction`, except that it was applied to a
keyed
- :class:`ConnectedStreams` and could register event-time and
processing-time timers.
- :class:`WindowFunction`:
Base interface for functions that are evaluated over keyed (grouped)
windows.
- :class:`ProcessWindowFunction`:
