pyflink.datastream.connectors.rabbitmq.RMQSink

class RMQSink(connection_config: RMQConnectionConfig, queue_name: str, serialization_schema: SerializationSchema)

Methods

get_java_function()