pyflink.datastream.connectors.rabbitmq.RMQSource#
- class RMQSource(connection_config: pyflink.datastream.connectors.rabbitmq.RMQConnectionConfig, queue_name: str, use_correlation_id: bool, deserialization_schema: pyflink.common.serialization.DeserializationSchema)[source]#
Methods
get_java_function()