but RMQ is not listed in the supported Taple API connectors, should I
define a custom source?
On Mon, Aug 23, 2021 at 4:56 AM Caizhi Weng wrote:
> Hi!
>
> You can first use the Table & SQL API to create a RMQ source table[1].
>
> Then you can use the to_data_stream method in TableEnvironment to
Hi!
You can first use the Table & SQL API to create a RMQ source table[1].
Then you can use the to_data_stream method in TableEnvironment to change
the table to a data stream.
[1]
https://ci.apache.org/projects/flink/flink-docs-stable/docs/dev/python/table/python_table_api_connectors/
Nadia Mos
Hello,
Is there any way to use RMQ as a data source in the DataStream python api?
Thanks in advance
