Vancior commented on code in PR #19743:
URL: https://github.com/apache/flink/pull/19743#discussion_r877773328
##########
flink-python/pyflink/datastream/__init__.py:
##########
@@ -141,6 +141,11 @@
- :class:`state.AggregatingState`:
Interface for aggregating state, based on an :class:`AggregateFunction`.
Elements that are
added to this type of state will be eagerly pre-aggregated using a given
AggregateFunction.
+ - :class:`state.BroadcastState`:
+ A type of state that can be created to store the state of a
:class:`BroadcastStream`. This
+ state assumes that the same elements are sent to all instances of an
operator.
+ - :class:`state.ReadOnlyBroadcastState`:
Review Comment:
Might be convenient for finding what operations can be done?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: issues-unsubscr...@flink.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
