[flink] branch master updated: [FLINK-27924][python][docs] Include pulsar in the list of supported connectors in DataStream (#19887)

[di...@apache.org]

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 8cd136bf86f [FLINK-27924][python][docs] Include pulsar in the list of supported connectors in DataStream (#19887)
8cd136bf86f is described below

commit 8cd136bf86ff5c35819c22712add1557cc352092
Author: LuNing Wang <wa...@gmail.com>
AuthorDate: Wed Jun 8 17:23:22 2022 +0800

    [FLINK-27924][python][docs] Include pulsar in the list of supported connectors in DataStream (#19887)
---
 flink-python/pyflink/datastream/__init__.py | 4 ++++
 1 file changed, 4 insertions(+)

diff --git a/flink-python/pyflink/datastream/__init__.py b/flink-python/pyflink/datastream/__init__.py
index a9c21196ba0..053ac8108a1 100644
--- a/flink-python/pyflink/datastream/__init__.py
+++ b/flink-python/pyflink/datastream/__init__.py
@@ -170,6 +170,10 @@ Classes to define source & sink:
     - :class:`connectors.StreamingFileSink`:
       Sink that emits its input elements to files within buckets. This is integrated with the
       checkpointing mechanism to provide exactly once semantics.
+    - :class:`connectors.PulsarSource`:
+      A streaming data source that pulls a parallel data stream from Pulsar.
+    - :class:`connectors.PulsarSink`:
+      A streaming data sink to produce data into Pulsar.
     - :class:`connectors.RMQSource`:
       A streaming data source that pulls a parallel data stream from RabbitMQ.
     - :class:`connectors.RMQSink`: