pyflink.datastream.connectors.rabbitmq.RMQSink#
- class RMQSink(connection_config: pyflink.datastream.connectors.rabbitmq.RMQConnectionConfig, queue_name: str, serialization_schema: pyflink.common.serialization.SerializationSchema)[source]#
Methods
get_java_function
()