package pulsar
Type Members
-
class
PulsarOutputWriter extends DatasourceWriter
A custom PulsarOutputWriter class that extends the DatasourceWriter.
A custom PulsarOutputWriter class that extends the DatasourceWriter. This class is responsible for writing data from a DataFrame to a Pulsar topic based on the specified options.
-
case class
PulsarWriterOptions(serviceUrl: String, adminUrl: String, topic: String, options: Map[String, String] = Map.empty) extends Product with Serializable
A case class representing the Pulsar writer options required for writing data from a DataFrame to a Pulsar topic.
A case class representing the Pulsar writer options required for writing data from a DataFrame to a Pulsar topic.
- serviceUrl
The Pulsar service URL in the format "pulsar://host:port".
- adminUrl
The Pulsar admin URL in the format "http://host:port".
- topic
The name of the Pulsar topic where data will be written.
- options
Additional options to be passed to the Pulsar writer (default: Map.empty).