c

io.dataos.spark.models.input

PulsarDatasourceInput

case class PulsarDatasourceInput(serviceUrl: String, adminUrl: String, tenant: String, namespace: String, topic: String, topicPattern: Option[String], options: Option[Map[String, String]], isBatch: Option[Boolean], incremental: Option[Incremental]) extends DatasourceInput with Product with Serializable

Represents a Pulsar datasource input configuration.

serviceUrl

The Pulsar service URL.

adminUrl

The Pulsar admin URL.

tenant

The Pulsar tenant.

namespace

The Pulsar namespace.

topic

The Pulsar topic.

topicPattern

The optional pattern for matching multiple topics. (Note: Avoid using this, as it can make it difficult to determine the input dataset.)

options

Additional options for the Pulsar input.

isBatch

Indicates if the Pulsar input is in batch mode.

incremental

The incremental configuration.

Linear Supertypes
Serializable, Serializable, Product, Equals, DatasourceInput, InputConfig, AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. PulsarDatasourceInput
  2. Serializable
  3. Serializable
  4. Product
  5. Equals
  6. DatasourceInput
  7. InputConfig
  8. AnyRef
  9. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. All

Instance Constructors

  1. new PulsarDatasourceInput(serviceUrl: String, adminUrl: String, tenant: String, namespace: String, topic: String, topicPattern: Option[String], options: Option[Map[String, String]], isBatch: Option[Boolean], incremental: Option[Incremental])

    serviceUrl

    The Pulsar service URL.

    adminUrl

    The Pulsar admin URL.

    tenant

    The Pulsar tenant.

    namespace

    The Pulsar namespace.

    topic

    The Pulsar topic.

    topicPattern

    The optional pattern for matching multiple topics. (Note: Avoid using this, as it can make it difficult to determine the input dataset.)

    options

    Additional options for the Pulsar input.

    isBatch

    Indicates if the Pulsar input is in batch mode.

    incremental

    The incremental configuration.

Value Members

  1. final def !=(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  2. final def ##(): Int
    Definition Classes
    AnyRef → Any
  3. final def ==(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  4. val adminUrl: String
  5. final def asInstanceOf[T0]: T0
    Definition Classes
    Any
  6. def clone(): AnyRef
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( ... ) @native()
  7. final def eq(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  8. def finalize(): Unit
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( classOf[java.lang.Throwable] )
  9. final def getClass(): Class[_]
    Definition Classes
    AnyRef → Any
    Annotations
    @native()
  10. val incremental: Option[Incremental]
  11. val isBatch: Option[Boolean]
  12. final def isInstanceOf[T0]: Boolean
    Definition Classes
    Any
  13. val namespace: String
  14. final def ne(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  15. final def notify(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native()
  16. final def notifyAll(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native()
  17. val options: Option[Map[String, String]]
  18. val serviceUrl: String
  19. final def synchronized[T0](arg0: ⇒ T0): T0
    Definition Classes
    AnyRef
  20. val tenant: String
  21. val topic: String
  22. val topicPattern: Option[String]
  23. final def wait(): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  24. final def wait(arg0: Long, arg1: Int): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  25. final def wait(arg0: Long): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... ) @native()

Inherited from Serializable

Inherited from Serializable

Inherited from Product

Inherited from Equals

Inherited from DatasourceInput

Inherited from InputConfig

Inherited from AnyRef

Inherited from Any

Ungrouped